Method enqueue

out/cli.cjs:8387–8417

(e3)

        }(this);
      }
      enqueue(e3) {
        if (!de(this)) throw Ae("enqueue");
        if ($5(e3, 1, "enqueue"), !ArrayBuffer.isView(e3)) throw new TypeError("chunk must be an array buffer view");
        if (0 === e3.byteLength) throw new TypeError("chunk must have non-zero byteLength");
        if (0 === e3.buffer.byteLength) throw new TypeError("chunk's buffer must have non-zero byteLength");
        if (this._closeRequested) throw new TypeError("stream is closed or draining");
        const t2 = this._controlledReadableByteStream._state;
        if ("readable" !== t2) throw new TypeError(`The stream (in ${t2} state) is not in the readable state and cannot be enqueued to`);
        !function(e4, t3) {
          const r3 = e4._controlledReadableByteStream;
          if (e4._closeRequested || "readable" !== r3._state) return;
          const o3 = t3.buffer, n2 = t3.byteOffset, a4 = t3.byteLength, i3 = o3;
          if (e4._pendingPullIntos.length > 0) {
            const t4 = e4._pendingPullIntos.peek();
            t4.buffer, 0, Re(e4), t4.buffer = t4.buffer, "none" === t4.readerType && ge(e4, t4);
          }
          if (J5(r3)) if (function(e5) {
            const t4 = e5._controlledReadableByteStream._reader;
            for (; t4._readRequests.length > 0; ) {
              if (0 === e5._queueTotalSize) return;
              We(e5, t4._readRequests.shift());
            }
          }(e4), 0 === X4(r3)) me(e4, i3, n2, a4);
          else {
            e4._pendingPullIntos.length > 0 && Ce(e4);
            G6(r3, new Uint8Array(i3, n2, a4), false);
          }
          else Le(r3) ? (me(e4, i3, n2, a4), Te(e4)) : me(e4, i3, n2, a4);
          be(e4);
        }(this, e3);
      }
      error(e3) {
        if (!de(this)) throw Ae("error");
        Pe(this, e3);