(controller)
| 653 | iterator = iterable[Symbol.asyncIterator]() |
| 654 | }, |
| 655 | pull (controller) { |
| 656 | return iterator.next().then(({ done, value }) => { |
| 657 | if (done) { |
| 658 | return queueMicrotask(() => { |
| 659 | controller.close() |
| 660 | controller.byobRequest?.respond(0) |
| 661 | }) |
| 662 | } else { |
| 663 | const buf = Buffer.isBuffer(value) ? value : Buffer.from(value) |
| 664 | if (buf.byteLength) { |
| 665 | return controller.enqueue(new Uint8Array(buf)) |
| 666 | } else { |
| 667 | return this.pull(controller) |
| 668 | } |
| 669 | } |
| 670 | }) |
| 671 | }, |
| 672 | cancel () { |
| 673 | return iterator.return() |
| 674 | }, |
nothing calls this directly
no test coverage detected
searching dependent graphs…