import type { Event, StreamOptions } from './types.js';
interface Manager {
    models: Record<string, {
        metadata: {
            actor: {
                _actorTypes?: string[];
                _eventTypes?: string[];
            };
        };
    }>;
    getSourceIds: (instance: unknown, source: string, id: unknown) => unknown;
}
interface Dispatcher {
    apply: (type: string, event: Event, instance: unknown) => Promise<void> | void;
}
interface ActorAdapterStream {
    fetchByLastEventId: (type: string, id: unknown, lastEventId: unknown) => Promise<unknown>;
    fetchByLastEventDate: (type: string, id: unknown, date: unknown) => Promise<unknown>;
}
interface EventAdapterStream {
    fetchStream: (type: string, id: unknown, options: Record<string, unknown>) => Promise<Iterable<Event> | AsyncIterable<Event>>;
}
export default function (manager?: Manager, dispatcher?: Dispatcher, actorAdapter?: ActorAdapterStream, eventAdapter?: EventAdapterStream): {
    getActorStream: ((actorType: string, actorId: unknown, options: StreamOptions) => AsyncGenerator<Record<string, unknown>, any, any>) | undefined;
    getEventStream: ((actorId: unknown, options: StreamOptions) => Promise<Iterable<Event>>) | undefined;
};
export {};