Function trackWritableLifecycle

deps/undici/undici.js:17731–17760

(stream2, callback)

    }
    __name(createPrematureCloseError, "createPrematureCloseError");
    function trackWritableLifecycle(stream2, callback) {
      let done = false;
      const cleanup = /* @__PURE__ */ __name(() => {
        stream2.removeListener("close", onClose);
        stream2.removeListener("error", onError);
        stream2.removeListener("finish", onFinish);
      }, "cleanup");
      const finish = /* @__PURE__ */ __name((err, fromErrorEvent = false) => {
        if (done) {
          return;
        }
        done = true;
        cleanup();
        callback(err, fromErrorEvent);
      }, "finish");
      const onClose = /* @__PURE__ */ __name(() => {
        const err = getWritableError(stream2);
        finish(err ?? (!stream2.writableFinished ? createPrematureCloseError() : void 0));
      }, "onClose");
      const onError = /* @__PURE__ */ __name((err) => finish(err, true), "onError");
      const onFinish = /* @__PURE__ */ __name(() => finish(), "onFinish");
      stream2.on("close", onClose);
      stream2.on("error", onError);
      stream2.on("finish", onFinish);
      if (stream2.closed) {
        process.nextTick(onClose);
      } else if (stream2.writableFinished) {
        process.nextTick(onFinish);
      }
    }
    __name(trackWritableLifecycle, "trackWritableLifecycle");
    var StreamHandler = class extends AsyncResource {
      static {