Function toLine

out/cli.cjs:78043–78112

(chunkIter)

function createMessage() {
  return {
    data: void 0,
    event: "",
    id: "",
    retry: void 0
  };
}
function toLine(chunkIter) {
  return __asyncGenerator(this, arguments, function* toLine_1() {
    var _a5, e_1, _b2, _c2;
    let buf;
    let bufIdx = 0;
    let fieldLen = -1;
    let discardTrailingNewline = false;
    try {
      for (var _d2 = true, chunkIter_1 = __asyncValues(chunkIter), chunkIter_1_1; chunkIter_1_1 = yield __await(chunkIter_1.next()), _a5 = chunkIter_1_1.done, !_a5; _d2 = true) {
        _c2 = chunkIter_1_1.value;
        _d2 = false;
        const chunk = _c2;
        if (buf === void 0) {
          buf = chunk;
          bufIdx = 0;
          fieldLen = -1;
        } else {
          buf = concatBuffer(buf, chunk);
        }
        const bufLen = buf.length;
        let start = 0;
        while (bufIdx < bufLen) {
          if (discardTrailingNewline) {
            if (buf[bufIdx] === ControlChars.NewLine) {
              start = ++bufIdx;
            }
            discardTrailingNewline = false;
          }
          let end = -1;
          for (; bufIdx < bufLen && end === -1; ++bufIdx) {
            switch (buf[bufIdx]) {
              case ControlChars.Colon:
                if (fieldLen === -1) {
                  fieldLen = bufIdx - start;
                }
                break;
              case ControlChars.CarriageReturn:
                discardTrailingNewline = true;
                end = bufIdx;
                break;
              case ControlChars.NewLine:
                end = bufIdx;
                break;
            }
          }
          if (end === -1) {
            break;
          }
          yield yield __await({ line: buf.subarray(start, end), fieldLen });
          start = bufIdx;
          fieldLen = -1;
        }