import type { ReadModelChangeset as ContractChangeset } from '@cratis/chronicle.contracts';
import type { ConnectionLifecycle } from '../connection/ConnectionLifecycle.js';
import type { IReadModelWatcher } from './IReadModelWatcher.js';
import type { ReadModelChangeset } from './ReadModelChangeset.js';
import type { ReadModelWatchOptions } from './ReadModelWatchOptions.js';
/** @internal Owns one cancellable stream per connection generation. */
export declare class ReadModelWatcher<TReadModel> implements IReadModelWatcher<TReadModel>, AsyncIterableIterator<ReadModelChangeset<TReadModel>> {
    private readonly _open;
    private readonly _convert;
    private readonly _lifecycle?;
    private static readonly _restartDelayMs;
    private readonly _bufferLimit;
    private readonly _failOnOverflow;
    private readonly _resume;
    private _resumeReading?;
    private _subscribed;
    private _resolveSubscribed;
    private _rejectSubscribed;
    private _acknowledged;
    private _hasSubscribed;
    private _delivery;
    private readonly _onResubscribed;
    private _controller?;
    private _stopped;
    private _failed;
    private _failure?;
    private readonly _buffered;
    private _restartTimer?;
    private readonly _waiting;
    private readonly _unsubscribe;
    constructor(_open: (signal: AbortSignal) => AsyncIterable<ContractChangeset>, _convert: (change: ContractChangeset) => Promise<ReadModelChangeset<TReadModel>>, signal: AbortSignal, _lifecycle?: ConnectionLifecycle | undefined, options?: ReadModelWatchOptions);
    get subscribed(): Promise<void>;
    onResubscribed(callback: () => void | Promise<void>): () => void;
    [Symbol.asyncIterator](): AsyncIterableIterator<ReadModelChangeset<TReadModel>>;
    next(): Promise<IteratorResult<ReadModelChangeset<TReadModel>>>;
    return(): Promise<IteratorResult<ReadModelChangeset<TReadModel>>>;
    dispose(): void;
    private resetReadiness;
    private start;
    private disconnect;
    private shouldResume;
    private restart;
    private clearRestartTimer;
    private cancelStream;
    private resumeReading;
    private waitForCapacity;
    private read;
    private deliver;
    private notifyResubscribed;
    private finish;
}
//# sourceMappingURL=ReadModelWatcher.d.ts.map