HACKS

Author: penberg

index.d.ts

@@ -44,5 +44,6 @@ export declare class Statement {
   raw(raw?: boolean | undefined | null): this
   get(params?: unknown | undefined | null): unknown
   safeIntegers(toggle?: boolean | undefined | null): this
+  interrupt(): void
 }
 export declare class RowsIterator { }

promise.js

@@ -268,7 +268,7 @@ class Statement {
   async all(...bindParameters) {
     try {
       const result = [];
-      const iterator = this.iterate(...bindParameters);
+      const iterator = await this.iterate(...bindParameters);
       let next;
       while (!(next = iterator.next()).done) {
         result.push(next.value);

src/lib.rs

@@ -307,8 +307,18 @@ impl Database {
     }
 
     #[napi]
-    pub fn interrupt(&self) -> Result<()> {
-        todo!();
+    pub fn interrupt(&self, env: Env) -> Result<()> {
+        let rt = runtime()?;
+        let conn = match &self.conn {
+            Some(conn) => conn.clone(),
+            None => return Err(throw_database_closed_error(&env).into()),
+        };
+        rt.block_on(async move {
+            let conn = conn.lock().await;
+            conn.interrupt()
+        })
+        .map_err(Error::from)?;
+        Ok(())
     }
 
     #[napi]
@@ -698,6 +708,17 @@ impl Statement {
             .store(toggle.unwrap_or(true), Ordering::SeqCst);
         Ok(self)
     }
+
+    #[napi]
+    pub fn interrupt(&self) -> Result<()> {
+        let rt = runtime()?;
+        rt.block_on(async move {
+            let mut stmt = self.stmt.lock().await;
+            stmt.interrupt()
+        })
+        .map_err(Error::from)?;
+        Ok(())
+    }
 }
 
 #[napi]