Function saveManyWithPureBatched_

packages/effect-app/src/Model/Repository/ext.ts:96–114

(
    items: Iterable<S1>,
    pure: Effect.Effect<A, E, FixEnv<R, Evt, readonly S1[], readonly S2[]>>,
    batchSize = 100
  )

    E | InvalidStateError | OptimisticConcurrencyException | DatabaseError,
    R | RSchema | RPublish
  > {
    return Effect.flatMap(gen, ([items, events, a]) => repo.saveAndPublish(items, events).pipe(Effect.map(() => a)))
  }

  function saveManyWithPureBatched_<
    R,
    A,
    E,
    S1 extends T,
    S2 extends T
  >(
    items: Iterable<S1>,
    pure: Effect.Effect<A, E, FixEnv<R, Evt, readonly S1[], readonly S2[]>>,
    batchSize = 100
  ) {
    return Effect.forEach(
      Array.chunksOf(items, batchSize),
      (batch) =>
        saveAllWithEffectInt(
          runTerm(pure, batch)
        )
    )