Function createStream

www/js/ext/eventsource.js:338–394

(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) {