errors and schedualling

browser.js

@@ -3,25 +3,43 @@
 var process = module.exports = {};
 var queue = [];
 var draining = false;
+var currentQueue;
+var queueIndex = -1;
+
+function cleanUpNextTick() {
+    draining = false;
+    if (currentQueue.length) {
+        queue = currentQueue.concat(queue);
+    } else {
+        queueIndex = -1;
+    }
+    if (queue.length) {
+        drainQueue();
+    }
+}
 
 function drainQueue() {
     if (draining) {
         return;
     }
+    var timeout = setTimeout(cleanUpNextTick);
     draining = true;
-    var currentQueue;
+
     var len = queue.length;
     while(len) {
         currentQueue = queue;
         queue = [];
-        var i = -1;
-        while (++i < len) {
-            currentQueue[i]();
+        while (++queueIndex < len) {
+            currentQueue[queueIndex]();
         }
+        queueIndex = -1;
         len = queue.length;
     }
+    currentQueue = null;
     draining = false;
+    clearTimeout(timeout);
 }
+
 process.nextTick = function (fun) {
     queue.push(fun);
     if (!draining) {

package.json

@@ -5,6 +5,9 @@
   "keywords": [
     "process"
   ],
+  "scripts": {
+    "test": "mocha test.js"
+  },
   "version": "0.10.1",
   "repository": {
     "type": "git",
@@ -14,5 +17,8 @@
   "main": "./index.js",
   "engines": {
     "node": ">= 0.6.0"
+  },
+  "devDependencies": {
+    "mocha": "2.2.1"
   }
 }

test.js

@@ -0,0 +1,29 @@
+var ourProcess = require('./browser');
+var assert = require('assert');
+
+describe('test errors', function (t) {
+    it ('works', function (done) {
+    var order = 0;
+    process.removeAllListeners('uncaughtException');
+    process.once('uncaughtException', function(err) {
+        assert.equal(2, order++, 'error is third');
+        process.nextTick(function () {
+            assert.equal(5, order++, 'schedualed in error is last');
+            done();
+        });
+    });
+    process.nextTick(function () {
+        assert.equal(0, order++, 'first one works');
+        process.nextTick(function () {
+        assert.equal(4, order++, 'recursive one is 4th');
+        });
+    });
+    process.nextTick(function () {
+        assert.equal(1, order++, 'second one starts');
+        throw(new Error('an error is thrown'));
+    });
+    process.nextTick(function () {
+        assert.equal(3, order++, '3rd schedualed happens after the error');
+    });
+    });
+});