Function naiveRateLimit

packages/infra/src/rateLimit.ts:106–126

(
  n: number,
  d: Duration.Duration
)

// }

export function naiveRateLimit(
  n: number,
  d: Duration.Duration
) {
  return <T>(items: Iterable<T>) => (<R, E, A, R2, E2, A2>(
    forEachItem: (i: T) => Effect.Effect<A, E, R>,
    forEachBatch: (a: A[]) => Effect.Effect<A2, E2, R2>
  ) =>
    Effect.forEach(
      Array.chunksOf(items, n),
      (batch, i) =>
        ((i === 0)
          ? Effect.void
          : Effect.sleep(d))
          .pipe(Effect.andThen(
            Effect
              .forEach(batch, forEachItem, { concurrency: n })
              .pipe(Effect.flatMap(forEachBatch))
          ))
    ))
}