/**
 * Wrapper for an {@link AsyncIterator} which allows multiple consumers
 * to read from the same iterable via a basic queue which tracks which
 * consumers have read which values.
 */
export declare class MultiAsyncIterator<T> implements AsyncIterable<T> {
    private readonly iteratorIds;
    private lastIteratorId;
    private readonly queue;
    private sourceDone;
    private thrown;
    private readonly upstream;
    private readonly waiting;
    constructor(upstream: (() => Promise<IteratorResult<T, undefined>>) | AsyncIterator<T, undefined>);
    [Symbol.asyncIterator](): AsyncIterator<T, undefined, undefined>;
    done(): void;
    onThrow(reason: unknown): IteratorResult<T, undefined>;
    private onValue;
    private onWaiting;
}
//# sourceMappingURL=multi-async-iterator.d.ts.map