Rev bpmux dep

lib/server.js

@@ -39,6 +39,7 @@ client). It also supports the following additional property:
 
   - `{Boolean} defer_to_final_handler` If `true` then a message stream is only
     considered finished when all `MQlobberServer` objects finish processing it.
+    Defaults to `false`.
 */
 function MQlobberServer(fsq, stream, options)
 {

package.json

@@ -1,7 +1,7 @@
 {
   "name": "mqlobber",
   "description": "Streaming message queue with pub-sub, work queues, wildcards and back-pressure. Just Node and a filesystem required.",
-  "version": "4.0.0",
+  "version": "4.0.1",
   "homepage": "https://github.com/davedoesdev/mqlobber",
   "author": {
     "name": "David Halls",
@@ -34,7 +34,7 @@
     "back-pressure"
   ],
   "dependencies": {
-    "bpmux": "~3.4.0",
+    "bpmux": "~4.0.0",
     "qlobber": "~0.7.0",
     "object.assign": "~4.0.4"
   },

test/runner.js

@@ -3244,20 +3244,21 @@ describe(type, function ()
                 this.read();
             });
 
-            cs.end();
-
             var mqclient = new MQlobberClient(cs);
 
             mqclient.on('error', function (err)
             {
                 expect(err.message).to.be.oneOf(
                 [
                     'carrier stream ended before end message received',
+                    'carrier stream finished before duplex finished',
                     'write after end'
                 ]);
                 errored = true;
                 check();
             });
+
+            cs.end();
         });
     });