Question about `Stream.runForEach` Concurrency and Fiber Forking

Is Stream.runForEach concurrent or should I fork the fiber?

Context:
I'm trying to make a quick WebTransport server using the @fails-components/webtransport package, but they only provide a streams based API (so no session callback available) which makes managing concurrent sessions painful (creating promises doesn't ensure those promises are awaited/canceled when closing, and I don't want to create a system for tracking live promises).

My plan is to wrap the
ReadableStream
with effect's Stream, then handle each session concurrently. So would I need to fork the fiber (I'm guessing yes)?
Was this page helpful?