From 4072b61c97f45d371f3a9334fa82fa50ddb394f4 Mon Sep 17 00:00:00 2001
From: David Halls <dahalls@gmail.com>
Date: Thu, 26 Jan 2017 21:10:34 +0000
Subject: [PATCH] Rev bpmux dep

---
 lib/server.js  | 1 +
 package.json   | 4 ++--
 test/runner.js | 5 +++--
 3 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/lib/server.js b/lib/server.js
index 2fbb81e..6ef6303 100644
--- a/lib/server.js
+++ b/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)
 {
diff --git a/package.json b/package.json
index 6624e60..3521b51 100644
--- a/package.json
+++ b/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"
   },
diff --git a/test/runner.js b/test/runner.js
index cb800ff..d225ba3 100644
--- a/test/runner.js
+++ b/test/runner.js
@@ -3244,8 +3244,6 @@ describe(type, function ()
                 this.read();
             });
 
-            cs.end();
-
             var mqclient = new MQlobberClient(cs);
 
             mqclient.on('error', function (err)
@@ -3253,11 +3251,14 @@ describe(type, function ()
                 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();
         });
     });