Function worker

packages/effect/test/Fiber.test.ts:144–149

(n: number)

        )
      }
      const worker = (n: number) => {
        if (n === 100) {
          return pipe(Queue.shutdown(queue), Effect.zipRight(Effect.fail("fail")))
        }
        return pipe(Queue.offer(queue, n), Effect.asVoid)
      }
      const queue = yield* Queue.unbounded<number>()
      yield* Queue.offerAll(queue, Array.range(1, 100))
      const result = yield* Effect.exit(shard(queue, 4, worker))