Allow eager start of the next queued query execution in Statement::All

alex3d · alex3d · commit 8b6656a590c9 · 2022-06-07T19:41:20.000+03:00
diff --git a/src/statement.cc b/src/statement.cc
@@ -579,8 +579,10 @@ void Statement::Work_AfterAll(napi_env e, napi_status status, void* data) {
 
     if (stmt->status != SQLITE_DONE) {
         Error(baton.get());
+        STATEMENT_END();
     }
     else {
+        STATEMENT_END();
         // Fire callbacks.
         Napi::Function cb = baton->callback.Value();
         if (!cb.IsUndefined() && cb.IsFunction()) {
@@ -607,8 +609,6 @@ void Statement::Work_AfterAll(napi_env e, napi_status status, void* data) {
             }
         }
     }
-
-    STATEMENT_END();
 }
 
 Napi::Value Statement::Each(const Napi::CallbackInfo& info) {

Original file line number	Diff line number	Diff line change
`@@ -579,8 +579,10 @@ void Statement::Work_AfterAll(napi_env e, napi_status status, void* data) {`
`579`	`579`
`580`	`580`	`if (stmt->status != SQLITE_DONE) {`
`581`	`581`	`Error(baton.get());`
	`582`	`+ STATEMENT_END();`
`582`	`583`	`}`
`583`	`584`	`else {`
	`585`	`+ STATEMENT_END();`
`584`	`586`	`// Fire callbacks.`
`585`	`587`	`Napi::Function cb = baton->callback.Value();`
`586`	`588`	`if (!cb.IsUndefined() && cb.IsFunction()) {`
`@@ -607,8 +609,6 @@ void Statement::Work_AfterAll(napi_env e, napi_status status, void* data) {`
`607`	`609`	`}`
`608`	`610`	`}`
`609`	`611`	`}`
`610`		`-`
`611`		`- STATEMENT_END();`
`612`	`612`	`}`
`613`	`613`
`614`	`614`	`Napi::Value Statement::Each(const Napi::CallbackInfo& info) {`