Function getAllUserNamesPipedN

packages/effect/test/Effect/query.test.ts:81–85

(concurrency: Concurrency)

  )

export const getAllUserNamesPipedN = (concurrency: Concurrency) =>
  getAllUserIds.pipe(
    Effect.flatMap(Effect.forEach(getUserNameById, { concurrency, batching: true })),
    Effect.onInterrupt(() => FiberRef.getWith(interrupts, (i) => Effect.sync(() => i.interrupts++)))
  )

export const getAllUserNames = getAllUserNamesN("unbounded")