import type { Event } from '@eventsource/eventstore/Event';
import { SubscribeOptions } from '@eventsource/eventstore/EventStore';
import * as R from 'fp-ts/Reader';
import type { MongoEvent } from '../EventStore';
export declare const subscribe: <E extends Event<import("@eventsource/eventstore/Event").EventType>>({ stream, fromRevision, signal }: SubscribeOptions) => R.Reader<{
    clockSkew?: number | undefined;
} & {
    collection: import("../EventStore").StoreCollection<E>;
    batchSize?: number | undefined;
} & {
    collection: {
        find: (filter: import("mongodb").Filter<import("../EventStore").StoreSchema<E>>, options?: import("mongodb").FindOptions<import("bson").Document> | undefined) => import("mongodb").FindCursor<import("../EventStore").StoreSchema<E>>;
    };
    batchSize?: number | undefined;
} & import("../EventStore").Dependencies<E>, AsyncIterable<MongoEvent<E>>>;
//# sourceMappingURL=subscribe.d.ts.map