UNPKG

963 BTypeScriptView Raw
1/// <reference types="node" />
2import { BufferLike } from '../interfaces';
3import { Readable, ReadableOptions } from 'stream';
4export declare class AsyncIterableReadable<T> extends Readable {
5 private _pulling;
6 private _objectMode;
7 private _iterator;
8 constructor(source: AsyncIterable<T>, options?: ReadableOptions);
9 _read(size: number): void;
10 _destroy(err: Error | null, cb: (err: Error | null) => void): void;
11 _pull(it: AsyncIterator<T>, size: number): Promise<boolean>;
12}
13export declare function toNodeStream<TSource>(source: AsyncIterable<TSource>): AsyncIterableReadable<TSource>;
14export declare function toNodeStream<TSource>(source: AsyncIterable<TSource>, options: ReadableOptions & {
15 objectMode: true;
16}): AsyncIterableReadable<TSource>;
17export declare function toNodeStream<TSource extends BufferLike>(source: AsyncIterable<TSource>, options: ReadableOptions & {
18 objectMode: false;
19}): AsyncIterableReadable<TSource>;