diff --git a/sqlite3/src/lib.rs b/sqlite3/src/lib.rs index 1a8309288..9fc0c9f15 100644 --- a/sqlite3/src/lib.rs +++ b/sqlite3/src/lib.rs @@ -1193,10 +1193,7 @@ pub unsafe extern "C" fn libsql_wal_get_frame( let db = db.inner.lock().unwrap(); let frame = std::slice::from_raw_parts_mut(p_frame, frame_len as usize); match db.conn.wal_get_frame(frame_no, frame) { - Ok(c) => match db.io.wait_for_completion(c) { - Ok(_) => SQLITE_OK, - Err(_) => SQLITE_ERROR, - }, + Ok(()) => SQLITE_OK, Err(_) => SQLITE_ERROR, } } @@ -1233,7 +1230,7 @@ pub unsafe extern "C" fn libsql_wal_insert_frame( let db = db.inner.lock().unwrap(); let frame = std::slice::from_raw_parts(p_frame, frame_len as usize); match db.conn.wal_insert_frame(frame_no, frame) { - Ok(()) => SQLITE_OK, + Ok(_) => SQLITE_OK, Err(LimboError::Conflict(..)) => { if !p_conflict.is_null() { *p_conflict = 1;