* Prefetch the first `bufferSize` items in this stream. * * Note this prefetches Promises, but makes no guarantees about when those * Promises resolve. * * @param bufferSize: An integer specifying the number of elements to be * prefetched.
(bufferSize: number)
| 450 | * prefetched. |
| 451 | */ |
| 452 | prefetch(bufferSize: number): LazyIterator<T> { |
| 453 | return new PrefetchIterator(this, bufferSize); |
| 454 | } |
| 455 | |
| 456 | // TODO(soergel): deep sharded shuffle, where supported |
| 457 |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…