File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -615,22 +615,19 @@ impl Statement {
615615 let safe_ints = self . safe_ints . load ( Ordering :: SeqCst ) ;
616616 let raw = self . raw . load ( Ordering :: SeqCst ) ;
617617 let pluck = self . pluck . load ( Ordering :: SeqCst ) ;
618- let params = {
619- let stmt = self . stmt . clone ( ) ;
620- rt . block_on ( async move {
621- let mut stmt = stmt . lock ( ) . await ;
618+ let stmt = self . stmt . clone ( ) ;
619+ let future = async move {
620+ let mut stmt = stmt . lock ( ) . await ;
621+ let params = {
622622 stmt. reset ( ) ;
623623 let params = if let Some ( params) = params {
624624 map_params ( & stmt, Some ( params) ) . unwrap ( )
625625 } else {
626626 libsql:: params:: Params :: None
627627 } ;
628628 params
629- } )
630- } ;
631- let stmt = self . stmt . clone ( ) ;
632- let future = async move {
633- let rows = stmt. lock ( ) . await . query ( params) . await . map_err ( Error :: from) ?;
629+ } ;
630+ let rows = stmt. query ( params) . await . map_err ( Error :: from) ?;
634631 Ok :: < _ , napi:: Error > ( rows)
635632 } ;
636633 let rows = rt. block_on ( future) ?;
You can’t perform that action at this time.
0 commit comments