aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-07 17:24:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix test with old buffer api

Browse Source
This commit is contained in:
PThorpe92
2025-08-02 14:07:23 -04:00
parent 0884fec799
commit 036ae596c4
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
tests/integration/query_processing/test_btree.rs
View File

@@ -428,10 +428,13 @@ impl BTreeGenerator<'_> {
}
fn write_at(io: &impl IO, file: Arc<dyn File>, offset: usize, data: &[u8]) {
let completion = Completion::new_write(|_| {});
let drop_fn = Rc::new(move |_| {});
#[allow(clippy::arc_with_non_send_sync)]
let buffer = Arc::new(Buffer::new(Pin::new(data.to_vec()), drop_fn));
let buffer = Arc::new(Buffer::new(data.to_vec()));
let _buf = buffer.clone();
let completion = Completion::new_write(|_| {
// reference the buffer to keep alive for async io
let _buf = _buf.clone();
});
let result = file.pwrite(offset, buffer, completion).unwrap();
while !result.is_completed() {
io.run_once().unwrap();