Function readStream

www/js/ext/eventsource.js:275–300

(stub, reader, ac)

    });
  }
  async function readStream(stub, reader, ac) {
    stub.reader = reader;
    var baseDelay = 500;
    try {
      for await (var msg of parseSSE(reader)) {
        if (ac.signal.aborted) break;
        if (msg.id) stub.lastEventId = msg.id;
        if (msg.retry != null) baseDelay = msg.retry;
        var eventType = msg.event || "message";
        var evt = {
          type: eventType,
          data: msg.data,
          lastEventId: msg.id || stub.lastEventId || ""
        };
        dispatch(stub, eventType, evt);
      }
    } catch (err) {
      if (!ac.signal.aborted) {
        dispatch(stub, "error", { type: "error", error: err });
      }
    }
    stub.reader = null;
    if (!stub.closed && !ac.signal.aborted) {
      scheduleReconnect(stub, baseDelay);
    }
  }
  function scheduleReconnect(stub, baseDelay) {
    if (stub.closed) return;
    baseDelay = baseDelay || 500;