Function handleError

packages/platform-node-shared/src/internal/sink.ts:47–49

(err: unknown)

) =>
  Effect.suspend(() => {
    function handleError(err: unknown) {
      Deferred.unsafeDone(deferred, Effect.fail(onError(err)))
    }
    writable.on("error", handleError)
    return Effect.ensuring(
      Deferred.await(deferred),