pubsub-stream

pubsub with rpc-stream and EventEmitter2

example

var port = 10000+Math.random()*10000|0
var net = require('net')
var EE2 = require('eventemitter2').EventEmitter2
var ee = new EE2({wildcard:true})
var server = net.createServer(function(s){s.pipe(pubsub(ee)).pipe(s)})

server.listen(port, function(){
  var todo = 2
  var Aps = pubsub()
  var Bps = pubsub()
  var Aclient = net.connect(port)
  var Bclient = net.connect(port)
  Aclient.pipe(Aps).pipe(Aclient)
  Bclient.pipe(Bps).pipe(Bclient)
  Aps.emitter.on('a.*', function(msg){t.equal(msg, 'hello from B'); done()})
  Bps.emitter.on('b.*', function(msg){t.equal(msg, 'hello from A'); done()})
  Aps.subscribe('a.*', function(){Bps.publish('a.foo', 'hello from B')})
  Bps.subscribe('b.*', function(){Aps.publish('b.foo', 'hello from A')})
  function done(){
    if (--todo) return
    Aclient.end()
    Bclient.end()
    server.close()
  }
})

api

var pubsub = require('pubsub')

var ps = pubsub([eeOrOpts])

• ps is a rpc-stream wrapped with [ 'publish', 'subscribe', 'unsubscribe', 'unsubscribeAll' ]
• eeOrOpts must be either a nodejs-eventemitter-compatible eventemitter or an object that gets passed to the EventEmitter2-constructor

ps.publish(event, data)

publish data

ps.subscribe(event, cb)

subscribe for remote events

ps.unsubscribe(event, cb)

delete all subscriptions for this event

ps.unsubscribeAll(cb)

deletes all subscribtions

ps.emitter

remote events you subscribed to will be emitted and the remote end can subscribe to this events

ps.subscriptions

ps.subscriptions = { 'some:event': [fn, ..], .. }

pubsub.emitterOptions

gets passed to the constructor of ps.emitter (EventEmitter2) if no arguments are passed to pubsub() and is { delimiter: '.', wildcard: true, maxListeners: 1e6 } by default