| 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 | }
|