🤖 feat: stream engine becomes the AppFiberScope occupant — dispose() aborts and awaits in-flight streams (Wave 4 PR 1) - #4070

Merged

ThomasK33 merged 9 commits into

mainfrom

effect-wave4-pr1-engine-supervisor

Sep 4, 2026

Commits on Sep 4, 2026

test(di): pin Effect.promise interruption + closed-scope forkIn semantics for the engine supervisor
ThomasK33
committed
782aeda
feat(streamManager): supervise the stream engine in AppFiberScope; latch cancels; guard completed streams from abort bookkeeping
ThomasK33
committed
0449c8c
test(streamManager): engine supervision cases; retire partial writes once the final message is committed
ThomasK33
committed
09e258d
test(streamManager.chaos): engine-scope close at a random iteration settles every stream exactly once
ThomasK33
committed
7cc88ab
test(di): dispose()/CLI cleanup abort and await an in-flight stream before the explicit teardown
ThomasK33
committed
22c3cd6
test: lint/type fixes for the supervision tests
ThomasK33
committed
8abed14
feat(streamManager): [shutdown] streamManager.abortStream debug line per supervised stream
ThomasK33
committed
b1d2a55
fix(streamManager): supervise from registration (STARTING window) and treat post-abort iterator rejections as cancellation
ThomasK33
committed
095dc9a
fix(streamManager): supervisor fiber is Fiber<void>
ThomasK33
committed
3d0b390