Function shard

packages/effect/test/Fiber.test.ts:128–143

(
        queue: Queue.Queue<A>,
        n: number,
        worker: (a: A) => Effect.Effect<void, E, R>
      )

  it.effect("shard example", () =>
    Effect.gen(function*() {
      const shard = <A, E, R>(
        queue: Queue.Queue<A>,
        n: number,
        worker: (a: A) => Effect.Effect<void, E, R>
      ): Effect.Effect<never, E, R> => {
        const worker1 = pipe(
          Queue.take(queue),
          Effect.flatMap((a) => Effect.uninterruptible(worker(a))),
          Effect.forever
        )
        return pipe(
          Effect.forkAll(Array.makeBy(n, () => worker1)),
          Effect.flatMap(Fiber.join),
          Effect.zipRight(Effect.never)
        )
      }
      const worker = (n: number) => {
        if (n === 100) {
          return pipe(Queue.shutdown(queue), Effect.zipRight(Effect.fail("fail")))