Function fromAsyncIterable

repos/effect/packages/effect/src/Channel.ts:1687–1703

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

                try: () => writer.ready.then(() => writer.write(value)),
                catch: options.onError
              }),
            { discard: true }
          )
        ),
        Effect.forever({ disableYield: true })
      )
      const withClose = options.closeOnDone !== false
        ? Pull.catchDone(loop, (done) =>
          Effect.andThen(
            Effect.tryPromise({
              try: () => writer.close(),
              catch: options.onError
            }),
            Cause.done(done)
          ))
        : loop
      return Effect.onError(
        withClose,
        (cause) =>
          Pull.isDoneCause(cause)