Function fromReadableStream

packages/effect/src/Channel.ts:1655–1667

(options: {
  readonly evaluate: LazyArg<ReadableStream<A>>
  readonly onError: (error: unknown) => E
  readonly releaseLockOnEnd?: boolean | undefined
})

 * @since 4.0.0
 */
export const fromReadableStream = <A, E>(options: {
  readonly evaluate: LazyArg<ReadableStream<A>>
  readonly onError: (error: unknown) => E
  readonly releaseLockOnEnd?: boolean | undefined
}): Channel<Arr.NonEmptyReadonlyArray<A>, E> =>
  fromTransform((_, scope) =>
    readableStreamToPullUnsafe({
      scope,
      readable: options.evaluate(),
      onError: options.onError,
      releaseLockOnEnd: options.releaseLockOnEnd
    })
  )

/** @internal */
export const pullIntoWritableStream = <A, IE, E>(options: {