Function makeBatched

packages/effect/src/internal/dataSource.ts:27–49

(
  run: (requests: RA.NonEmptyArray<A>) => Effect.Effect<void, never, R>
)

/** @internal */
export const makeBatched = <A extends Request.Request<any, any>, R>(
  run: (requests: RA.NonEmptyArray<A>) => Effect.Effect<void, never, R>
): RequestResolver.RequestResolver<A, R> =>
  new core.RequestResolverImpl<A, R>(
    (requests) => {
      if (requests.length > 1) {
        return core.forEachSequentialDiscard(requests, (block) => {
          const filtered = block.filter((_) => !_.state.completed).map((_) => _.request)
          if (!RA.isNonEmptyArray(filtered)) {
            return core.void
          }
          return invokeWithInterrupt(run(filtered), block)
        })
      } else if (requests.length === 1) {
        const filtered = requests[0].filter((_) => !_.state.completed).map((_) => _.request)
        if (!RA.isNonEmptyArray(filtered)) {
          return core.void
        }
        return run(filtered)
      }
      return core.void
    }
  )

/** @internal */
export const around = dual<