(concurrency: Concurrency)
| 73 | export const getUserNameByIdPiped = (id: number) => pipe(new GetNameById({ id }), Effect.request(UserResolver)) |
| 74 | |
| 75 | export const getAllUserNamesN = (concurrency: Concurrency) => |
| 76 | getAllUserIds.pipe( |
| 77 | Effect.flatMap(Effect.forEach(getUserNameById, { concurrency, batching: true })), |
| 78 | Effect.onInterrupt(() => FiberRef.getWith(interrupts, (i) => Effect.sync(() => i.interrupts++))) |
| 79 | ) |
| 80 | |
| 81 | export const getAllUserNamesPipedN = (concurrency: Concurrency) => |
| 82 | getAllUserIds.pipe( |
no test coverage detected