Managing the Fibers of multiple Effects running at my program's edge (with FiberSet?)
I am making a function that runs my Effects, like this:
I want the function to immediately run the given effect in the given runtime, and also register an event listener to interrupt all Fibers still running. My first attempt was the following:
Here I zip the old fiber into a new fiber, to ensure that when the resulting fiber is interrupted, so is the old one. However, I think this would create a memory leak.
Instead, I should probably be using a
<R>(runtime: ManagedRuntime<R, never>) => (eff: Effect<unknown, never, R>) => voidI want the function to immediately run the given effect in the given runtime, and also register an event listener to interrupt all Fibers still running. My first attempt was the following:
Here I zip the old fiber into a new fiber, to ensure that when the resulting fiber is interrupted, so is the old one. However, I think this would create a memory leak.
Instead, I should probably be using a
FiberSetEffect.forkIn
Similar Threads
Was this page helpful?
