Expose as _onExecutionProgress

Author: carlopi

packages/duckdb-wasm/src/log.ts

@@ -47,6 +47,9 @@ export type ProgressEntry = {
     readonly repetitions: string;
 }
 
+/** An execution progress handler */
+export type ExecutionProgressHandler = (p: ProgressEntry) => void;
+
 export type LogEntryVariant =
     | LogEntry<LogOrigin.BINDINGS, LogTopic.INSTANTIATE, LogEvent.ERROR, string>
     | LogEntry<LogOrigin.BINDINGS, LogTopic.QUERY, LogEvent.START, void>

packages/duckdb-wasm/src/parallel/async_bindings.ts

@@ -18,6 +18,7 @@ import { InstantiationProgress } from '../bindings/progress';
 import { arrowToSQLField } from '../json_typedef';
 import { WebFile } from '../bindings/web_file';
 import { DuckDBDataProtocol } from '../bindings';
+import { ProgressEntry } from '../log';
 
 const TEXT_ENCODER = new TextEncoder();
 
@@ -33,7 +34,7 @@ export class AsyncDuckDB implements AsyncDuckDBBindings {
     protected _onInstantiationProgress: ((p: InstantiationProgress) => void)[] = [];
 
     /** Progress callbacks */
-    //protected _onProgressCallback: ((p: InstantiationProgress) => void)[] = [];
+    protected _onExecutionProgress: ((p: ProgressEntry) => void)[] = [];
 
     /** The logger */
     protected readonly _logger: Logger;
@@ -126,7 +127,9 @@ export class AsyncDuckDB implements AsyncDuckDBBindings {
         switch (response.type) {
             // Request failed?
             case WorkerResponseType.PROGRESS_UPDATE: {
-		console.log(response.data);
+                for (const p of this._onExecutionProgress) {
+		    p(response.data);
+		}
                 return;
 	    }
             case WorkerResponseType.LOG: {