1 files changed, 56 insertions, 0 deletions
diff --git a/dom/base/test/delayedServerEvents.sjs b/dom/base/test/delayedServerEvents.sjs
new file mode 100644
index 0000000000..cfc1bca508
--- /dev/null
+++ b/dom/base/test/delayedServerEvents.sjs
@@ -0,0 +1,56 @@
+// this will take strings_to_send.length*500 ms = 5 sec
+
+var timer = null;
+var strings_to_send = [
+  "retry:999999999\ndata\r\n\nda",
+  "ta",
+  ":",
+  "de",
+  "layed1\n\n",
+  "",
+  "",
+  "data:delayed2\n\n",
+  "",
+  "",
+];
+var resp = null;
+
+function sendNextString() {
+  if (!strings_to_send.length) {
+    timer.cancel();
+    resp.finish();
+    timer = null;
+    resp = null;
+    return;
+  }
+
+  try {
+    resp.write(strings_to_send.shift());
+  } catch (e) {
+    timer.cancel();
+    timer = null;
+    resp = null;
+  }
+}
+
+function handleRequest(request, response) {
+  var bytes = strings_to_send.reduce((len, s) => len + s.length, 0);
+
+  response.seizePower();
+  response.write("HTTP/1.1 200 OK\r\n");
+  response.write(`Content-Length: ${bytes}\r\n`);
+  response.write("Content-Type: text/event-stream; charset=utf-8\r\n");
+  response.write("Cache-Control: no-cache, must-revalidate\r\n");
+  response.write("\r\n");
+
+  resp = response;
+
+  timer = Components.classes["@mozilla.org/timer;1"].createInstance(
+    Components.interfaces.nsITimer
+  );
+  timer.initWithCallback(
+    sendNextString,
+    500,
+    Components.interfaces.nsITimer.TYPE_REPEATING_SLACK
+  );
+}