(
protected upstream: LazyIterator<T>, protected bufferSize: number)
| 1100 | protected buffer: RingBuffer<Promise<IteratorResult<T>>>; |
| 1101 | |
| 1102 | constructor( |
| 1103 | protected upstream: LazyIterator<T>, protected bufferSize: number) { |
| 1104 | super(); |
| 1105 | this.buffer = new RingBuffer<Promise<IteratorResult<T>>>(bufferSize); |
| 1106 | } |
| 1107 | |
| 1108 | summary() { |
| 1109 | return `${this.upstream.summary()} -> Prefetch`; |
nothing calls this directly
no outgoing calls
no test coverage detected