Skip to content

Commit cca242d

Browse files
committed
Remove redundant block_on() from Statement.iterate()
1 parent 666414a commit cca242d

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

src/lib.rs

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -761,18 +761,12 @@ impl Statement {
761761
/// * `params` - The parameters to bind to the statement.
762762
#[napi]
763763
pub fn iterate(&self, env: Env, params: Option<napi::JsUnknown>) -> Result<napi::JsObject> {
764-
let rt = runtime()?;
765764
let safe_ints = self.mode.safe_ints.load(Ordering::SeqCst);
766765
let raw = self.mode.raw.load(Ordering::SeqCst);
767766
let pluck = self.mode.pluck.load(Ordering::SeqCst);
768767
let stmt = self.stmt.clone();
769-
let params = {
770-
let stmt = stmt.clone();
771-
rt.block_on(async move {
772-
stmt.reset();
773-
map_params(&stmt, params).unwrap()
774-
})
775-
};
768+
stmt.reset();
769+
let params = map_params(&stmt, params).unwrap();
776770
let stmt = self.stmt.clone();
777771
let future = async move {
778772
let rows = stmt.query(params).await.map_err(Error::from)?;

0 commit comments

Comments
 (0)