MCPcopy Create free account
hub / github.com/Effect-TS/effect / fromFunctionBatched

Function fromFunctionBatched

packages/effect/src/RequestResolver.ts:393–405  ·  view source on GitHub ↗
(
  f: (entries: NonEmptyArray<Request.Entry<A>>) => Iterable<Request.Success<A>>
)

Source from the content-addressed store, hash-verified

391 * @since 2.0.0
392 */
393export const fromFunctionBatched = <A extends Request.Any>(
394 f: (entries: NonEmptyArray<Request.Entry<A>>) => Iterable<Request.Success<A>>
395): RequestResolver<A> =>
396 make(
397 (entries) =>
398 Effect.sync(() => {
399 let i = 0
400 for (const result of f(entries)) {
401 const entry = entries[i++]
402 entry.completeUnsafe(exitSucceed(result))
403 }
404 })
405 )
406
407/**
408 * Constructs a request resolver from an effectual function.

Callers

nothing calls this directly

Calls 4

completeUnsafeMethod · 0.80
makeFunction · 0.70
fFunction · 0.50
syncMethod · 0.45

Tested by

no test coverage detected