import { EventEmitter } from 'node:events';
import type { Event } from './types.js';
interface Dispatcher {
    apply: (type: string, event: Event, baseline: unknown) => Promise<void>;
}
interface ActorAdapterEmitter {
    fetchByLastEventId: () => Promise<unknown>;
    fetchByLastEventDate: () => Promise<unknown>;
}
interface EventAdapterEmitter {
    fetchStream: (type: string, sinceValue: unknown) => EventEmitter;
}
interface StreamOptions {
    sinceEventId?: unknown;
    sinceDate?: unknown;
    eventTypes?: string[];
    actorTypes: string[];
}
declare function checkQueues(queues: Record<string, unknown[]>, count: number, depth: number): boolean;
declare function checkSetIntersection(a: string[], b: string[]): boolean;
declare function chooseEvents(queues: Record<string, Event[]>): Event[];
declare function depthCheck(queues: Record<string, unknown[]>, depth: number): boolean;
declare function findTypeById(queues: Record<string, Event[]>, id: string): string | undefined;
declare function getIdSeriesFromIndex(queues: Record<string, Event[]>, index: number): string[];
declare function mergeAndSort(queues: Record<string, Event[]>): Event[];
declare function removeEmpty(emptied: Record<string, boolean>, queues: Record<string, (Event | undefined)[]>, cb?: () => void): void;
export default function (manager: unknown, dispatcher: Dispatcher, actorAdapter: ActorAdapterEmitter, eventAdapter: EventAdapterEmitter): {
    checkQueues: typeof checkQueues;
    checkSetIntersection: typeof checkSetIntersection;
    chooseEvents: typeof chooseEvents;
    depthCheck: typeof depthCheck;
    findTypeById: typeof findTypeById;
    getActorStream: (actorType: string, _actorId: unknown, options: StreamOptions) => Promise<EventEmitter<[never]>>;
    getEventStream: (options: StreamOptions) => EventEmitter<[never]>;
    getIdSeriesFromIndex: typeof getIdSeriesFromIndex;
    mergeAndSort: typeof mergeAndSort;
    removeEmpty: typeof removeEmpty;
};
export {};