Function fromWritableChannel

packages/platform-node-shared/src/internal/sink.ts:19–39

(
  writable: LazyArg<Writable | NodeJS.WritableStream>,
  onError: (error: unknown) => OE,
  options?: FromWritableOptions
)

/** @internal */
export const fromWritableChannel = <IE, OE, A>(
  writable: LazyArg<Writable | NodeJS.WritableStream>,
  onError: (error: unknown) => OE,
  options?: FromWritableOptions
): Channel.Channel<Chunk.Chunk<never>, Chunk.Chunk<A>, IE | OE, IE, void, unknown> =>
  Channel.flatMap(
    Effect.zip(
      Effect.sync(() => writable()),
      Deferred.make<void, IE | OE>()
    ),
    ([writable, deferred]) =>
      Channel.embedInput(
        writableOutput(writable, deferred, onError),
        writeInput<IE, A>(
          writable,
          (cause) => Deferred.failCause(deferred, cause),
          options,
          Deferred.complete(deferred, Effect.void)
        )
      )
  )

const writableOutput = <IE, E>(
  writable: Writable | NodeJS.WritableStream,