Chore: Allow disposing worker projection proxy more than once

Author: snatalenko

src/workers/WorkerProxyProjection.ts

@@ -32,6 +32,7 @@ export class WorkerProxyProjection<
 	readonly #remoteView: Comlink.Remote<TView>;
 	readonly #logger?: ILogger;
 	readonly #messageTypes: string[];
+	#disposed = false;
 	viewLocker?: IViewLocker = new InMemoryLock();
 
 	get remoteProjection(): Comlink.Remote<TProjection> {
@@ -160,6 +161,10 @@ export class WorkerProxyProjection<
 	}
 
 	dispose() {
+		if (this.#disposed)
+			return;
+
+		this.#disposed = true;
 		this.#remoteProjection[Comlink.releaseProxy]();
 		this.#remoteView[Comlink.releaseProxy]();
 		this.#worker?.terminate();

tests/integration/workers/AbstractWorkerProjection.test.ts

@@ -127,6 +127,14 @@ describe('AbstractWorkerProjection', () => {
 		expect(await projectionProxy.view.getCounter()).toBe(1);
 	});
 
+	it('allows disposing the projection proxy more than once', async () => {
+
+		await projectionProxy.ensureWorkerReady();
+
+		expect(() => projectionProxy.dispose()).not.toThrow();
+		expect(() => projectionProxy.dispose()).not.toThrow();
+	});
+
 	it('awaits project calls while restoring', async () => {
 
 		const eventStore = createEventStore([