Skip to content

Commit aa9fcc8

Browse files
committed
Cleanups
1 parent 9ad62ef commit aa9fcc8

1 file changed

Lines changed: 10 additions & 21 deletions

File tree

src/lib.rs

Lines changed: 10 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -809,26 +809,15 @@ impl RowsIterator {
809809
let safe_ints = self.safe_ints;
810810
let raw = self.raw;
811811
let pluck = self.pluck;
812-
let rows = self.rows.clone();
813-
let mut rows = rows.lock().await;
814-
let next_row = rows.next().await.map_err(Error::from)?;
815-
let record = match next_row {
816-
Some(row) => Record {
817-
column_names,
818-
row: Some(row),
819-
safe_ints,
820-
raw,
821-
pluck,
822-
},
823-
None => Record {
824-
column_names,
825-
row: None,
826-
safe_ints,
827-
raw,
828-
pluck,
829-
},
830-
};
831-
Ok(record)
812+
let mut rows = self.rows.lock().await;
813+
let row = rows.next().await.map_err(Error::from)?;
814+
Ok(Record {
815+
row,
816+
column_names,
817+
safe_ints,
818+
raw,
819+
pluck,
820+
})
832821
}
833822
}
834823

@@ -840,8 +829,8 @@ pub fn iterator_next_sync(iter: &RowsIterator) -> Result<Record> {
840829

841830
#[napi]
842831
pub struct Record {
843-
column_names: Vec<std::ffi::CString>,
844832
row: Option<libsql::Row>,
833+
column_names: Vec<std::ffi::CString>,
845834
safe_ints: bool,
846835
raw: bool,
847836
pluck: bool,

0 commit comments

Comments
 (0)