multiplex test

index.js

var multiplex = require('multiplex');

var a = multiplex(function(stream, meta){
  console.log('a meta', meta)
})

var b = multiplex(function(stream, meta){
  console.log('b meta', meta)
})

a.pipe(b).pipe(a)

a.createStream('foo')
a.createStream('foo')
b.createStream('foo')
b.createStream('foo')

out.txt

 ∴  mt : node index.js
b meta foo
b meta foo
a meta foo
a meta foo

package.json

{
  "dependencies": {
    "multiplex": "^5.0.0"
  }
}