Function toMessage

out/cli.cjs:78113–78160

(lineIter)

      try {
        if (!_d2 && !_a5 && (_b2 = chunkIter_1.return)) yield __await(_b2.call(chunkIter_1));
      } finally {
        if (e_1) throw e_1.error;
      }
    }
  });
}
function toMessage(lineIter) {
  return __asyncGenerator(this, arguments, function* toMessage_1() {
    var _a5, e_2, _b2, _c2;
    let message = createMessage();
    const decoder = new TextDecoder();
    try {
      for (var _d2 = true, lineIter_1 = __asyncValues(lineIter), lineIter_1_1; lineIter_1_1 = yield __await(lineIter_1.next()), _a5 = lineIter_1_1.done, !_a5; _d2 = true) {
        _c2 = lineIter_1_1.value;
        _d2 = false;
        const { line, fieldLen } = _c2;
        if (line.length === 0 && message.data !== void 0) {
          yield yield __await(message);
          message = createMessage();
        } else if (fieldLen > 0) {
          const field = decoder.decode(line.subarray(0, fieldLen));
          const valueOffset = fieldLen + (line[fieldLen + 1] === ControlChars.Space ? 2 : 1);
          const value = decoder.decode(line.subarray(valueOffset));
          switch (field) {
            case "data":
              message.data = message.data ? message.data + "\n" + value : value;
              break;
            case "event":
              message.event = value;
              break;
            case "id":
              message.id = value;
              break;
            case "retry": {
              const retry = parseInt(value, 10);
              if (!isNaN(retry)) {
                message.retry = retry;
              }
              break;
            }
          }
        }
      }
    } catch (e_2_1) {
      e_2 = { error: e_2_1 };
    } finally {
      try {
        if (!_d2 && !_a5 && (_b2 = lineIter_1.return)) yield __await(_b2.call(lineIter_1));
      } finally {
        if (e_2) throw e_2.error;
      }