Function fromDuplex

packages/platform-node-shared/src/internal/stream.ts:111–135

(
  evaluate: LazyArg<Duplex>,
  onError: (error: unknown) => E,
  options?: FromReadableOptions & FromWritableOptions
)

/** @internal */
export const fromDuplex = <IE, E, I = string | Uint8Array<ArrayBufferLike>, O = Uint8Array<ArrayBufferLike>>(
  evaluate: LazyArg<Duplex>,
  onError: (error: unknown) => E,
  options?: FromReadableOptions & FromWritableOptions
): Channel.Channel<
  Chunk.Chunk<O>,
  Chunk.Chunk<I>,
  IE | E,
  IE
> =>
  Channel.suspend(() => {
    const duplex = evaluate()
    if (!duplex.readable) {
      return Channel.void
    }
    const exit = MutableRef.make<Exit.Exit<void, IE | E> | undefined>(undefined)
    return Channel.embedInput(
      unsafeReadableRead<O, IE | E>(duplex, onError, exit, options),
      writeInput<IE, I>(
        duplex,
        (cause) => Effect.sync(() => MutableRef.set(exit, Exit.failCause(cause))),
        options
      )
    )
  })

/** @internal */
export const pipeThroughDuplex = dual<