Handling FiberSet Finalization and Error Propagation in Effect.gen

I have a

FiberSet

FiberSet

FiberSet

FiberSet within an

Effect.gen

Effect.gen

Effect.gen

Effect.gen.

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

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

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

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

I populate this

FiberSet

FiberSet

FiberSet

FiberSet with a

Stream.fromQueue

Stream.fromQueue

Stream.fromQueue

Stream.fromQueue.

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

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

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

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

When the

Scope

Scope

Scope

Scope is closed, I want the pubsub to stop listening. However, I don't want the

fibers

fibers

fibers

fibers to be killed.

It initially seemed I could add a finalizer to await the

fiberset

fiberset

fiberset

fiberset. Ie.

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

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

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

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

Unfortunately, finalizer effects cannot contain error / this wouldn't propagate errors within

fibers

fibers

fibers

fibers to

root

root

root

root. Ideally, the

E

E of

f

f-produced effects would be represented in

root

root

root

root.

Any tips on how to ensure the

fibers

fibers

fibers

fibers are all resolved / stop the completed parent fiber from terminating

fibers

fibers

fibers

fibers?

No replies yetBe the first to reply to this messageJoin

Handling FiberSet Finalization and Error Propagation in Effect.gen

Similar Threads

Similar Threads

Similar Threads