aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-25 03:54:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix clippy

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-08-12 18:33:12 +04:00
parent d3a27ee311
commit bf2a01866c
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packages/turso-sync-engine/src/database_tape.rs
View File

@@ -60,9 +60,9 @@ pub(crate) async fn run_stmt_once<'a>(
}
}
pub(crate) async fn run_stmt_expect_one_row<'a>(
coro: &'_ Coro,
stmt: &'a mut turso_core::Statement,
pub(crate) async fn run_stmt_expect_one_row(
coro: &Coro,
stmt: &mut turso_core::Statement,
) -> Result<Option<Vec<turso_core::Value>>> {
let Some(row) = run_stmt_once(coro, stmt).await? else {
return Ok(None);
@@ -71,14 +71,14 @@ pub(crate) async fn run_stmt_expect_one_row<'a>(
let None = run_stmt_once(coro, stmt).await? else {
return Err(Error::DatabaseTapeError("single row expected".to_string()));
};
return Ok(Some(values));
Ok(Some(values))
}
pub(crate) async fn run_stmt_ignore_rows(
coro: &Coro,
stmt: &mut turso_core::Statement,
) -> Result<()> {
while let Some(_) = run_stmt_once(coro, stmt).await? {}
while run_stmt_once(coro, stmt).await?.is_some() {}
Ok(())
}