diff --git a/src/client/workerclient.ts b/src/client/workerclient.ts index 901e86c..31154ae 100644 --- a/src/client/workerclient.ts +++ b/src/client/workerclient.ts @@ -70,7 +70,6 @@ export class WorkerClient extends BaseClient { shards = new Map(); resharding = new Map(); private _ready?: boolean; - private __setServicesCache?: boolean; declare options: WorkerClientOptions; @@ -95,8 +94,8 @@ export class WorkerClient extends BaseClient { setServices(rest: ServicesOptions) { super.setServices(rest); - if (rest.cache?.adapter) { - this.__setServicesCache = true; + if (this.options.postMessage && rest.cache?.adapter instanceof WorkerAdapter) { + rest.cache.adapter.postMessage = this.options.postMessage; } } @@ -122,19 +121,6 @@ export class WorkerClient extends BaseClient { name: `[Worker #${workerData.workerId}]`, }); - if (this.__setServicesCache) delete this.__setServicesCache; - else { - const adapter = new WorkerAdapter(workerData); - if (this.options.postMessage) { - adapter.postMessage = this.options.postMessage; - } - this.setServices({ - cache: { - adapter, - }, - }); - } - if (workerData.debug) { this.debugger = new Logger({ name: `[Worker #${workerData.workerId}]`,