()
| 411 | closeStream() |
| 412 | } |
| 413 | const closeScope = () => { |
| 414 | if (closed) { |
| 415 | return Effect.void |
| 416 | } |
| 417 | |
| 418 | closed = true |
| 419 | stop() |
| 420 | return Scope.close(scope, Exit.void) |
| 421 | } |
| 422 | |
| 423 | input.signal?.addEventListener("abort", halt, { once: true }) |
| 424 | yield* Effect.addFinalizer(() => closeScope()) |
no test coverage detected