do max listener stuff to avoid those error messages

thenables · Aug 22, 2014 · aa2aad5 · aa2aad5
1 parent 471140f
commit aa2aad5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/master.js b/master.js
@@ -52,13 +52,15 @@ function Master(filename, options) {
     var args = slice.call(arguments)
     var proc = runner.select()
     proc.queue++
+    proc._maxListeners++
     var id = _id++
 
     return new Promise(function (resolve, reject) {
       proc.on('message', function onmessage(res) {
         if (res.id !== id) return
-        proc.queue--
         proc.removeListener('message', onmessage)
+        proc.queue--
+        proc._maxListeners--
         if ('value' in res) return resolve(res.value)
         else reject(JSONToError(res.error))
       })

diff --git a/test/index.js b/test/index.js
@@ -60,7 +60,7 @@ describe('Slave', function () {
     })
 
     var fns = []
-    for (var i = 0; i < 10; i++) (function (i) {
+    for (var i = 0; i < 100; i++) (function (i) {
       fns.push(fn(i).then(function (val) {
         assert.equal(val, i)
       }))