import { ReadModelChangeset } from '@cratis/chronicle.contracts';
export declare class a_kernel_stream implements AsyncIterableIterator<ReadModelChangeset> {
    private readonly _messages;
    private _waiting?;
    signal: AbortSignal;
    closed: boolean;
    pulls: number;
    [Symbol.asyncIterator](): this;
    next(): Promise<IteratorResult<ReadModelChangeset>>;
    return(): Promise<IteratorResult<ReadModelChangeset>>;
    send(change: Partial<ReadModelChangeset>): void;
    end(): void;
    fail(error: unknown): void;
}
//# sourceMappingURL=a_kernel_stream.d.ts.map