| ... | ... | @@ -2817,16 +2817,25 @@ const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* ( |
| 2817 | 2817 | providerRefs: {}, |
| 2818 | 2818 | }); |
| 2819 | 2819 | |
| 2820 | | const streamFiber = runFork(runSdkStream(context)); |
| 2820 | let streamFiber: Fiber.Fiber<void, never>; |
| 2821 | streamFiber = runFork( |
| 2822 | Effect.exit(runSdkStream(context)).pipe( |
| 2823 | Effect.flatMap((exit) => { |
| 2824 | if (context.stopped) { |
| 2825 | return Effect.void; |
| 2826 | } |
| 2827 | if (context.streamFiber === streamFiber) { |
| 2828 | context.streamFiber = undefined; |
| 2829 | } |
| 2830 | return handleStreamExit(context, exit); |
| 2831 | }), |
| 2832 | ), |
| 2833 | ); |
| 2821 | 2834 | context.streamFiber = streamFiber; |
| 2822 | | streamFiber.addObserver((exit) => { |
| 2823 | | if (context.stopped) { |
| 2824 | | return; |
| 2825 | | } |
| 2835 | streamFiber.addObserver(() => { |
| 2826 | 2836 | if (context.streamFiber === streamFiber) { |
| 2827 | 2837 | context.streamFiber = undefined; |
| 2828 | 2838 | } |
| 2829 | | runFork(handleStreamExit(context, exit)); |
| 2830 | 2839 | }); |
| 2831 | 2840 | |
| 2832 | 2841 | return { |
Julius Marminge <julius0216@outlook.com> 2026-03-28 16:13:52-07:00
GitHub <noreply@github.com> 2026-03-28 16:13:52-07:00