(controller)
| 25 | ? null |
| 26 | : new ReadableStream({ |
| 27 | start(controller) { |
| 28 | message.on('data', chunk => controller.enqueue(chunk)) |
| 29 | message.on('end', () => controller.close()) |
| 30 | message.on('error', error => controller.error(error)) |
| 31 | signal.addEventListener('abort', () => message.destroy(signal.reason)) |
| 32 | }, |
| 33 | cancel() { |
| 34 | message.destroy() |
| 35 | }, |
nothing calls this directly
no test coverage detected
searching dependent graphs…