Dont error

index.js

@@ -1,6 +1,6 @@
 var es = require('event-stream')
 
-function MuxDemux (name) {
+function MuxDemux (opts) {
 
   function createID() {
     return (
@@ -32,14 +32,18 @@ function MuxDemux (name) {
   })
 
   function destroyAll (_err) {
-    md.removeListener('end', destroyAll) 
-    md.removeListener('error', destroyAll) 
-    md.removeListener('close', destroyAll) 
+    md.removeListener('end', destroyAll)
+    md.removeListener('error', destroyAll)
+    md.removeListener('close', destroyAll)
     var err = _err || new Error ('unexpected disconnection')
     for (var i in streams) {
       var s = streams[i]
-      s.emit('error', err)
-      s.destroy()
+      if (opts && opts.error === false) {
+        s.end()
+      } else {
+        s.emit('error', err)
+        s.destroy()
+      }
     }
   }
 
@@ -57,14 +61,14 @@ function MuxDemux (name) {
         throw new Error('stream is not writable')
       md.emit('data', [s.id, 'data', data])
     }, function () {
-      md.emit('data', [s.id, 'end']) 
+      md.emit('data', [s.id, 'end'])
     })
     s.pause = function () {
       md.emit('data', [s.id, 'pause'])
     }
     s.resume = function () {
       md.emit('data', [s.id, 'resume'])
-    } 
+    }
     s.once('close', function () {
       md.emit('data', [s.id, 'close'])
       delete streams[id]
@@ -73,7 +77,7 @@ function MuxDemux (name) {
     s.readable = opts.readable
     streams[s.id = id] = s
     s.meta = meta
-    return s 
+    return s
   }
 
   var outer = es.connect(es.split(), es.parse(), md, es.stringify())
@@ -88,15 +92,15 @@ function MuxDemux (name) {
     pipe.call(outer, dest, opts)
     md.on('end', destroyAll)
     md.on('close', destroyAll)
-    md.on('error', destroyAll) 
+    md.on('error', destroyAll)
     return dest
   }
 
   outer.createStream = function (meta, opts) {
     opts = opts || {writable: true, readable: true}
     var s = createStream(createID(), meta, opts)
     var _opts = {writable: opts.readable, readable: opts.writable}
-    md.emit('data', [s.id, 'new', {meta: meta, opts: _opts}]) 
+    md.emit('data', [s.id, 'new', {meta: meta, opts: _opts}])
     return s
   }
   outer.createWriteStream = function (meta) {

package.json

@@ -14,7 +14,8 @@
     "test": "tap test/*.js"
   },
   "devDependencies": {
-    "assertions": "2.3"
+    "assertions": "2.3",
+    "tap": "~0.3.0"
   },
   "author": "Dominic Tarr <dominic.tarr@gmail.com> (dominictarr.com)",
   "optionalDependencies": {},

readme.markdown

@@ -53,6 +53,16 @@ client.createStream(meta)
 there is actually no distinction between clients and servers.
 if both sides are listening `on('connection',...)` then both sides may call `create{Write,Read,}Stream(meta)` and initiate new streams.
 
+### MuxDemux(options)
+
+Creates a MuxDemux stream. Optionally pass in an options hash 
+
+    {
+        error: Boolean
+    }
+
+If the error option is set to false then MuxDemux won't emit errors on the streams on unexpected disconnects and instead just end those streams
+
 ### createReadStream (meta)
 
 open a `ReadableStream` from the other side.