From e1d4a00a930cb11ad5b8513cf66f2003156edca1 Mon Sep 17 00:00:00 2001 From: Siddharth Singh Date: Wed, 7 May 2025 07:06:12 +0530 Subject: [PATCH] add close method to policyworker for testing purposes --- packages/ditto/workers/policy.ts | 4 ++++ packages/ditto/workers/policy.worker.ts | 4 ++++ 2 files changed, 8 insertions(+) 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());