1 |
|
2 | import { AsyncIterableX } from './asynciterablex';
|
3 | export declare class ReadableStreamAsyncIterable extends AsyncIterableX<string | Buffer> implements AsyncIterator<string | Buffer> {
|
4 | private _stream;
|
5 | private _defaultSize?;
|
6 | private _state;
|
7 | private _error;
|
8 | private _rejectFns;
|
9 | private _endPromise;
|
10 | constructor(stream: NodeJS.ReadableStream, size?: number);
|
11 | [Symbol.asyncIterator](): AsyncIterator<string | Buffer>;
|
12 | next(size?: number | undefined): Promise<IteratorResult<string | Buffer>>;
|
13 | private _waitReadable;
|
14 | private _waitEnd;
|
15 | }
|
16 | export declare function fromNodeStream(stream: NodeJS.ReadableStream, size?: number): AsyncIterableX<string | Buffer>;
|