/// <reference types="node" />
import { EventEmitter } from "events";
declare type listenFunctionType = (...args: unknown[]) => void;
export interface PubSubOptions {
    eventEmitter?: EventEmitter;
}
export declare class PubSub {
    private ee;
    private subscriptions;
    private subIdCounter;
    constructor(options?: PubSubOptions);
    publish(triggerName: string, payload: Record<string, unknown>): Promise<void>;
    subscribe(triggerName: string, onMessage: listenFunctionType): Promise<number>;
    unsubscribe(subId: number): boolean;
    asyncIterator<T>(triggerNames: string | string[]): AsyncIterator<T>;
}
export {};