Function fromTransformStream

packages/effect/src/Channel.ts:1784–1816

(options: {
  readonly evaluate: LazyArg<TransformStream<I, O>>
  readonly onError: (error: unknown) => E
  readonly closeOnDone?: boolean | undefined
  readonly releaseLockOnEnd?: boolean | undefined
})

 * @since 4.0.0
 */
export const fromTransformStream = <IE, I, O, E>(options: {
  readonly evaluate: LazyArg<TransformStream<I, O>>
  readonly onError: (error: unknown) => E
  readonly closeOnDone?: boolean | undefined
  readonly releaseLockOnEnd?: boolean | undefined
}): Channel<Arr.NonEmptyReadonlyArray<O>, IE | E, void, Arr.NonEmptyReadonlyArray<I>, IE> =>
  fromTransform((upstream, scope) => {
    const transform = options.evaluate()
    const exit = MutableRef.make<Exit.Exit<never, IE | E | Cause.Done> | undefined>(undefined)
    return pullIntoWritableStream({
      pull: upstream,
      writable: transform.writable,
      onError: options.onError,
      closeOnDone: options.closeOnDone
    }).pipe(
      Effect.catchCause((cause) => {
        if (!Pull.isDoneCause(cause)) {
          exit.current = Exit.failCause(cause as Cause.Cause<IE | E | Cause.Done>)
        }
        return Effect.void
      }),
      Effect.forkIn(scope),
      Effect.flatMap(() =>
        readableStreamToPullUnsafe({
          scope,
          exit,
          readable: transform.readable,
          onError: options.onError,
          releaseLockOnEnd: options.releaseLockOnEnd
        })
      )
    )
  })

const readableStreamToPullUnsafe = <A, E, E2 = never>(options: {
  readonly scope: Scope.Scope