(controller)
| 16 | |
| 17 | const rs = new ReadableStream({ |
| 18 | start(controller) { |
| 19 | // Pre-fill the buffer |
| 20 | for (let i = 0; i < bufferSize; i++) { |
| 21 | controller.enqueue('a'); |
| 22 | enqueued++; |
| 23 | } |
| 24 | }, |
| 25 | pull(controller) { |
| 26 | // Refill buffer when pulled |
| 27 | const toEnqueue = Math.min(bufferSize, n - enqueued); |
nothing calls this directly
no test coverage detected
searching dependent graphs…