Function createStream

www/js/ext/eventsource.esm.js:337–393

(response, runtime, context)

  return data;
}
function createStream(response, runtime, context) {
  var element = context.me;
  var reader = response.body.getReader();
  var messages = [];
  var waiting = null;
  var done = false;
  (async function() {
    try {
      for await (var msg of parseSSE(reader)) {
        var eventType = msg.event || "message";
        if (msg.event) {
          runtime.triggerEvent(element, eventType, {
            data: msg.data,
            lastEventId: msg.id || ""
          });
        } else {
          messages.push(msg.data);
          if (waiting) {
            waiting.resolve({ value: msg.data, done: false });
            waiting = null;
          }
        }
      }
    } catch (err) {
      runtime.triggerEvent(element, "stream-error", { error: err });
    }
    done = true;
    if (waiting) {
      waiting.resolve({ value: void 0, done: true });
      waiting = null;
    }
    runtime.triggerEvent(element, "streamEnd", {});
  })();
  var stream = {
    element,
    [Symbol.asyncIterator]: function() {
      var index = 0;
      return {
        next: function() {
          if (index < messages.length) {
            return Promise.resolve({ value: messages[index++], done: false });
          }
          if (done) {
            return Promise.resolve({ value: void 0, done: true });
          }
          return new Promise(function(resolve) {
            waiting = { resolve };
          }).then(function(result) {
            if (!result.done) index++;
            return result;
          });
        }
      };
    }
  };
  return stream;
}
var streamConversion = function(response, runtime, context) {