public async peek(): Promise<T | typeof AsyncReaderEndOfStream> {
await this._extendBuffer();
}
if (this._buffer.length === 0) {
return AsyncReaderEndOfStream;
}
return this._buffer[0];
public peekBufferedOrThrow(): T | typeof AsyncReaderEndOfStream {