@reactivex/ix-esnext-esm/asynciterable/fromnodestream.d.ts

/// <reference types="node" />
import { AsyncIterableX } from './asynciterablex';
export declare class ReadableStreamAsyncIterable extends AsyncIterableX<string | Buffer> implements AsyncIterator<string | Buffer> {
    private _stream;
    private _defaultSize?;
    private _state;
    private _error;
    private _rejectFns;
    private _endPromise;
    constructor(stream: NodeJS.ReadableStream, size?: number);
    [Symbol.asyncIterator](): AsyncIterator<string | Buffer>;
    next(size?: number | undefined): Promise<IteratorResult<string | Buffer>>;
    private _waitReadable;
    private _waitEnd;
}
export declare function fromNodeStream(stream: NodeJS.ReadableStream, size?: number): AsyncIterableX<string | Buffer>;