diff --git a/packages/ditto/workers/policy.ts b/packages/ditto/workers/policy.ts index 32eb9691..885fd4a9 100644 --- a/packages/ditto/workers/policy.ts +++ b/packages/ditto/workers/policy.ts @@ -86,4 +86,8 @@ export class PolicyWorker implements NPolicy { throw new Error(`DITTO_POLICY (error importing policy): ${conf.policy}`); } } + + [Symbol.dispose]() { + this.worker.close(); + } } diff --git a/packages/ditto/workers/policy.worker.ts b/packages/ditto/workers/policy.worker.ts index 8b15c695..8df16b45 100644 --- a/packages/ditto/workers/policy.worker.ts +++ b/packages/ditto/workers/policy.worker.ts @@ -85,6 +85,10 @@ export class CustomPolicy implements NPolicy { this.policy = new PipePolicy(policies); } + + close() { + self.close(); + } } Comlink.expose(new CustomPolicy());