Function process

packages/experimental/src/RequestResolver.ts:57–69

(items: Iterable<DataLoaderItem<A>>)

    let batch = new Set<DataLoaderItem<A>>()
    const process = (items: Iterable<DataLoaderItem<A>>) =>
      Effect.withRequestCaching(
        Effect.forEach(
          items,
          ({ request, resume }) =>
            Effect.request(request, self).pipe(
              Effect.exit,
              Effect.map(resume)
            ),
          { batching: true, discard: true }
        ),
        false
      )
    const delayedProcess = Effect.sleep(options.window).pipe(
      Effect.flatMap(() => {
        const currentBatch = batch