import { Worker, WorkerOptions } from 'node:worker_threads';
import { BaseHelper } from '../../base/base.helper';
import { AnyType, ValueOrPromise } from '../../common/types';
import { IWorker, IWorkerBus, IWorkerThread } from './types';
export declare abstract class AbstractWorkerHelper<MessageType> extends BaseHelper implements IWorker<MessageType> {
    worker: Worker;
    options: WorkerOptions;
    abstract onOnline(): ValueOrPromise<void>;
    abstract onExit(opts: {
        code: string | number;
    }): ValueOrPromise<void>;
    abstract onError(opts: {
        error: Error;
    }): ValueOrPromise<void>;
    abstract onMessage(opts: {
        message: MessageType;
    }): ValueOrPromise<void>;
    abstract onMessageError(opts: {
        error: Error;
    }): ValueOrPromise<void>;
}
export declare class BaseWorkerHelper<MessageType> extends AbstractWorkerHelper<MessageType> {
    protected eventHandlers?: Partial<Pick<IWorker<MessageType>, 'onOnline' | 'onExit' | 'onError' | 'onMessage' | 'onMessageError'>>;
    constructor(opts: {
        scope?: string;
        identifier: string;
        path: string | URL;
        options: WorkerOptions;
        eventHandlers?: Partial<Pick<IWorker<MessageType>, 'onOnline' | 'onExit' | 'onError' | 'onMessage' | 'onMessageError'>>;
    });
    onOnline(): ValueOrPromise<void>;
    onExit(opts: {
        code: string | number;
    }): ValueOrPromise<void>;
    onError(opts: {
        error: Error;
    }): ValueOrPromise<void>;
    onMessage(opts: {
        message: MessageType;
    }): ValueOrPromise<void>;
    onMessageError(opts: {
        error: Error;
    }): ValueOrPromise<void>;
    binding(): void;
}
export declare abstract class AbstractWorkerThreadHelper extends BaseHelper implements IWorkerThread {
    buses: {
        [workerKey: string | symbol]: IWorkerBus<AnyType, AnyType>;
    };
    abstract bindWorkerBus<IC, IP>(opts: {
        key: string;
        bus: IWorkerBus<IC, IP>;
    }): ValueOrPromise<void>;
    abstract getWorkerBus<IC, IP>(opts: {
        key: string;
    }): IWorkerBus<IC, IP>;
}
export declare class BaseWorkerThreadHelper extends AbstractWorkerThreadHelper {
    constructor(opts: {
        scope: string;
    });
    bindWorkerBus<IC, IP>(opts: {
        key: string;
        bus: IWorkerBus<IC, IP>;
    }): void;
    unbindWorkerBus(opts: {
        key: string;
    }): void;
    getWorkerBus<IC, IP>(opts: {
        key: string;
    }): IWorkerBus<IC, IP>;
}
//# sourceMappingURL=base.d.ts.map