Handling FiberSet Finalization and Error Propagation in Effect.gen

const root = Effect.gen(function*() {
  const fibers = yield* FiberSet.make<void, E>()
  // ...
}).pipe(
  Effect.scoped
)

  // ...
  const dequeue = yield* pubsub.subscribe
  yield* Stream.fromQueue(dequeue).pipe(
    Stream.runForEach(f),
    FiberSet.run(fibers),
  )
  // ...

  yield* Effect.addFinalizer(() => FiberSet.join(fibers))