(next)
| 318 | return new Response( |
| 319 | new ReadableStream<Uint8Array>({ |
| 320 | start(next) { |
| 321 | controller = next |
| 322 | options.signal?.addEventListener("abort", onAbort, { once: true }) |
| 323 | |
| 324 | if (options.signal?.aborted) { |
| 325 | onAbort() |
| 326 | return |
| 327 | } |
| 328 | |
| 329 | attach(socket) |
| 330 | }, |
| 331 | cancel(reason) { |
| 332 | onCancel(reason) |
| 333 | }, |
nothing calls this directly
no test coverage detected