(controller)
| 23 | } |
| 24 | }, |
| 25 | pull(controller) { |
| 26 | // Refill buffer when pulled |
| 27 | const toEnqueue = Math.min(bufferSize, n - enqueued); |
| 28 | for (let i = 0; i < toEnqueue; i++) { |
| 29 | controller.enqueue('a'); |
| 30 | enqueued++; |
| 31 | } |
| 32 | if (enqueued >= n) { |
| 33 | controller.close(); |
| 34 | } |
| 35 | }, |
| 36 | }, { |
| 37 | // Use buffer size as high water mark to allow pre-buffering |
| 38 | highWaterMark: bufferSize, |