Function writableOutput

packages/platform-node-shared/src/internal/sink.ts:41–57

(
  writable: Writable | NodeJS.WritableStream,
  deferred: Deferred.Deferred<void, IE | E>,
  onError: (error: unknown) => E
)

  )

const writableOutput = <IE, E>(
  writable: Writable | NodeJS.WritableStream,
  deferred: Deferred.Deferred<void, IE | E>,
  onError: (error: unknown) => E
) =>
  Effect.suspend(() => {
    function handleError(err: unknown) {
      Deferred.unsafeDone(deferred, Effect.fail(onError(err)))
    }
    writable.on("error", handleError)
    return Effect.ensuring(
      Deferred.await(deferred),
      Effect.sync(() => {
        writable.removeListener("error", handleError)
      })
    )
  })