import type { Event } from '@eventsource/eventstore/Event';
import { SubscribeToAllOptions } from '@eventsource/eventstore/EventStore';
import * as R from 'fp-ts/Reader';
import type { MongoEvent } from '../EventStore';
export declare const subscribeToAll: <E extends Event<import("@eventsource/eventstore/Event").EventType>>({ fromPosition, signal }?: SubscribeToAllOptions) => R.Reader<{
    collection: import("../EventStore").StoreCollection<E>;
    batchSize?: number | undefined;
} & {
    clockSkew?: number | undefined;
    subscribeStart?: number | undefined;
} & {
    collection: import("../EventStore").StoreCollection<E>;
    batchSize?: number | undefined;
}, AsyncIterable<MongoEvent<E>>>;
//# sourceMappingURL=subscribeToAll.d.ts.map