private _extendBuffer(): Promise<void> {
return Promise.resolve();
}
if (!this._extendBufferPromise) {
this._extendBufferPromise = (async () => {
const { value, done } = await this._source.next();
this._extendBufferPromise = undefined;
if (done) {
this._atEnd = true;
this._buffer.push(value);
}
}
return this._extendBufferPromise;
}
}