Function fromAsyncIterable

packages/effect/src/Channel.ts:1867–1883

(
  iterable: AsyncIterable<A, D>,
  onError: (error: unknown) => E
)

 * @since 4.0.0
 */
export const fromAsyncIterable = <A, D, E>(
  iterable: AsyncIterable<A, D>,
  onError: (error: unknown) => E
): Channel<A, E, D> =>
  fromTransform(Effect.fnUntraced(function*(_, scope) {
    const iter = iterable[Symbol.asyncIterator]()
    if (iter.return) {
      yield* Scope.addFinalizer(scope, Effect.promise(() => iter.return!()))
    }
    return Effect.flatMap(
      Effect.tryPromise({
        try: () => iter.next(),
        catch: onError
      }),
      (result) => result.done ? Cause.done(result.value) : Effect.succeed(result.value)
    )
  }))

/**
 * Creates a channel from an `AsyncIterable`, emitting each yielded value as a