app/drivers/chrome/src/dispatch.js in flok-0.0.38 vs app/drivers/chrome/src/dispatch.js in flok-0.0.39

@@ -5,10 +5,17 @@
 //Here is an example with one call
 //  [1, 'print', 'hello world']
 //Here is an example with two successive calls
 //  [2, 'mul', 3, 4, 1, 'print', 'hello world']
 function if_dispatch(qq) {
+  if (qq[0] == 'i') {
+    qq.shift();
+    if_dispatch_call_int_end = true
+  } else {
+    if_dispatch_call_int_end = false
+  }
+
   //If debug socket is attached, forward events to it
   //and do not process the events
   <% if @mods.include? "debug" %>
     if (debug_socket && debug_socket_if_forward) {
       debug_socket.emit("if_dispatch", qq);
@@ -20,24 +27,49 @@
     var q = qq.shift();
 
     //The very first thing is the queue type
     var queueType = q.shift();
 
-    //Where there is still things left on the queue
-    while (q.length > 0) {
-      //Grab the first thing off the queue, this is the arg count
-      var argc = q.shift();
+    //Main queue events are run synchronously on w.r.t to this thread of execution
+    //Asynchronous events are dispatched individually
+    if (queueType === 0) {
+      //Where there is still things left on the queue
+      while (q.length > 0) {
+        //Grab the first thing off the queue, this is the arg count
+        var argc = q.shift();
 
-      //Grab the next thing and look that up in the function table. Pass args left
-      this[q.shift()].apply(null, q.splice(0, argc));
+        //Grab the next thing and look that up in the function table. Pass args left
+        this[q.shift()].apply(null, q.splice(0, argc));
+      }
+    } else {
+        //Dispatch asynchronous queue events
+        while (q.length > 0) {
+          //Grab the next thing and look that up in the function table. Pass args left
+          function({
+            var argc = q.shift();
+            var q0 = q.shift();
+            var q1 = q.splice(0, argc);
+            async_call = function() {
+              this[q0].apply(null, q1);
+            }
+
+            setTimeout(async_call, 0);
+          })();
+        }
     }
   }
 
   //Continuation of the debug_socket at linke 10
   <% if @mods.include? "debug" %>
     }
   <% end %>
+
+
+  if (if_dispatch_call_int_end) {
+    if_dispatch_call_int_end = false;
+    int_dispatch([])
+  }
 }
 
 function ping() {
   int_dispatch([0, "pong"])
 }
@@ -47,6 +79,9 @@
 }
 
 function ping2(arg1, arg2) {
   int_dispatch([1, "pong2", arg1])
   int_dispatch([2, "pong2", arg1, arg2])
+}
+
+function ping_nothing() {
 }