tiramisu/seyfert
5
0
Fork 0
mirror of https://github.com/tiramisulabs/seyfert.git synced 2025-07-02 04:56:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: remove WorkerAdapter (#296)

Browse Source 
* chore: dont set WorkerAdapter by default

* fix: set postMessage
This commit is contained in:
MARCROCK22 2024-11-14 18:57:36 -04:00 committed by GitHub
parent 961bff0e27
commit a3b28d9f7d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/client/workerclient.ts
View File

@ -70,7 +70,6 @@ export class WorkerClient<Ready extends boolean = boolean> extends BaseClient {
shards = new Map<number, Shard>();
resharding = new Map<number, Shard>();
private _ready?: boolean;
private __setServicesCache?: boolean;
declare options: WorkerClientOptions;
@ -95,8 +94,8 @@ export class WorkerClient<Ready extends boolean = boolean> 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<Ready extends boolean = boolean> 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}]`,