public async read(): Promise<T | typeof AsyncReaderEndOfStream> {
await this._extendBuffer();
}
return AsyncReaderEndOfStream;
}
return this._buffer.shift()!;
public async readWhile(predicate: (value: T) => boolean, callback: (element: T) => unknown): Promise<void> {