import type { Event } from '@eventsource/eventstore/Event';
import { ReadFromStreamOptions } from '@eventsource/eventstore/EventStore';
import { Filter, FindCursor, FindOptions } from 'mongodb';
import type { MongoEvent, StoreSchema } from '../EventStore';
declare type Dependencies<E extends Event, S extends StoreSchema<E> = StoreSchema<E>> = {
    collection: {
        find: (filter: Filter<S>, options?: FindOptions) => FindCursor<StoreSchema<E>>;
    };
    batchSize?: number;
};
export declare const readStream: <E2 extends Event<import("@eventsource/eventstore/Event").EventType>>({ stream, fromRevision, direction, maxCount, signal, }: ReadFromStreamOptions) => <E extends E2>({ collection, batchSize }: Dependencies<E, StoreSchema<E>>) => AsyncIterable<MongoEvent<E>>;
export {};
//# sourceMappingURL=readStream.d.ts.map