Function end

lib/internal/streams/iter/classic.js:670–690

()

    // options.signal is ignored for the same reason as write().
    end() {
      if ((writable.writableFinished ?? false) ||
          (writable.destroyed ?? false)) {
        cleanup();
        return PromiseResolve(totalBytes);
      }

      const { promise, resolve, reject } = PromiseWithResolvers();

      if (!(writable.writableEnded ?? false)) {
        writable.end();
      }

      eos(writable, { writable: true, readable: false }, (err) => {
        cleanup(err);
        if (err) reject(err);
        else resolve(totalBytes);
      });

      return promise;
    },

    fail(reason) {
      cleanup(reason);