1 | export declare class AsyncSink<TSource> implements AsyncIterableIterator<TSource> {
|
2 | private _ended;
|
3 | private _values;
|
4 | private _resolvers;
|
5 | constructor();
|
6 | [Symbol.asyncIterator](): this;
|
7 | write(value: TSource): void;
|
8 | error(error: any): void;
|
9 | private _push;
|
10 | next(): Promise<IteratorResult<TSource, any>>;
|
11 | end(): void;
|
12 | }
|