export declare class Receiver<T> {
    recv: () => Promise<T | null>;
    close: () => boolean;
    constructor(recv: () => Promise<T | null>, close: () => boolean);
    [Symbol.asyncIterator](): AsyncGenerator<T>;
    forEach: (f: (msg: T) => unknown) => Promise<void>;
    collect: () => Promise<T[]>;
}