MCPcopy Create free account
hub / github.com/effect-app/libs / fromAsyncIterableArray

Function fromAsyncIterableArray

repos/effect/packages/effect/src/Channel.ts:1718–1721  ·  view source on GitHub ↗
(
  iterable: AsyncIterable<A, D>,
  onError: (error: unknown) => E
)

Source from the content-addressed store, hash-verified

1716 return Effect.onError(
1717 withClose,
1718 (cause) =>
1719 Pull.isDoneCause(cause)
1720 ? Effect.void
1721 : Effect.promise(() => writer.abort(cause).catch(constVoid))
1722 )
1723 },
1724 (writer) => Effect.sync(() => writer.releaseLock())

Callers

nothing calls this directly

Calls 2

fromAsyncIterableFunction · 0.70
mapFunction · 0.50

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…