Function void_

packages/sql/src/SqlResolver.ts:417–463

(
  tag: T,
  options:
    | {
      readonly Request: Schema.Schema<I, II, RI>
      readonly execute: (
        requests: Array<Types.NoInfer<II>>
      ) => Effect.Effect<ReadonlyArray<unknown>, E>
      readonly withContext?: false
    }
    | {
      readonly Request: Schema.Schema<I, II, RI>
      readonly execute: (
        requests: Array<Types.NoInfer<II>>
      ) => Effect.Effect<unknown, E, R>
      readonly withContext: true
    }
)

  return makeResolver(resolver, tag, options.Id, options.withContext)
}
const void_ = <T extends string, I, II, RI, E, R = never>(
  tag: T,
  options:
    | {
      readonly Request: Schema.Schema<I, II, RI>
      readonly execute: (
        requests: Array<Types.NoInfer<II>>
      ) => Effect.Effect<ReadonlyArray<unknown>, E>
      readonly withContext?: false
    }
    | {
      readonly Request: Schema.Schema<I, II, RI>
      readonly execute: (
        requests: Array<Types.NoInfer<II>>
      ) => Effect.Effect<unknown, E, R>
      readonly withContext: true
    }
): Effect.Effect<SqlResolver<T, I, void, E, RI>, never, R> => {
  const resolver = RequestResolver.makeBatched(
    (requests: NonEmptyArray<SqlRequest<T, void, E>>) => {
      const [inputs, spanLinks] = partitionRequests(requests)
      return options.execute(inputs as any).pipe(
        Effect.andThen(
          Effect.forEach(
            requests,
            (request) => Request.complete(request, Exit.void),
            { discard: true }
          )
        ),
        Effect.catchAllCause((cause) =>
          Effect.forEach(
            requests,
            (request) => Request.failCause(request, cause),
            { discard: true }
          )
        ),
        Effect.withSpan(`sql.Resolver.batch ${tag}`, {
          kind: "client",
          links: spanLinks,
          attributes: { "request.count": inputs.length },
          captureStackTrace: false
        })
      ) as Effect.Effect<void>
    }
  ).identified(`@effect/sql/SqlResolver.void/${tag}`)
  return makeResolver(resolver, tag, options.Request, options.withContext)
}

export {
  /**