(chunk, controller)
| 454 | |
| 455 | const createObserverTransform = (stream) => new TransformStream({ |
| 456 | transform(chunk, controller) { |
| 457 | processChunk(chunk, stream); |
| 458 | controller.enqueue(chunk); |
| 459 | }, |
| 460 | flush() { |
| 461 | closeConnection(stream); |
| 462 | } |
nothing calls this directly
no test coverage detected