Processor can send transferrable objects out

DallasHoff · Aug 6, 2024 · 2ea16db · 2ea16db
1 parent 9ae2131
commit 2ea16db
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 5 deletions.
diff --git a/src/processor.ts b/src/processor.ts
@@ -36,7 +36,9 @@ export class SQLocalProcessor {
 
 	protected proxy: WorkerProxy;
 
-	onmessage: ((message: OutputMessage) => void) | undefined;
+	onmessage:
+		| ((message: OutputMessage, transfer: Transferable[]) => void)
+		| undefined;
 
 	constructor(worker: typeof globalThis) {
 		this.proxy = coincident(worker) as WorkerProxy;
@@ -123,9 +125,12 @@ export class SQLocalProcessor {
 		await this.initMutex.unlock();
 	};
 
-	protected emitMessage = (message: OutputMessage): void => {
+	protected emitMessage = (
+		message: OutputMessage,
+		transfer: Transferable[] = []
+	): void => {
 		if (this.onmessage) {
-			this.onmessage(message);
+			this.onmessage(message, transfer);
 		}
 	};
 

diff --git a/src/worker.ts b/src/worker.ts
@@ -2,5 +2,10 @@ import { SQLocalProcessor } from './processor.js';
 
 const processor = new SQLocalProcessor(self);
 
-self.onmessage = (message) => processor.postMessage(message);
-processor.onmessage = (message) => self.postMessage(message);
+self.onmessage = (message) => {
+	processor.postMessage(message);
+};
+
+processor.onmessage = (message, transfer) => {
+	self.postMessage(message, transfer);
+};