Publish-Subscribe node streams style, based on mqemitter.
$ npm install mqemitter mqstreams --save
'use strict'var mqemitter =var mqstreams =var emitter =var through =var input = emittervar output = emitteremitterinputinputinputoutput
Extends the MQEmitter with the
stream in object mode that will include all emitter messages that match
the given topic. The
opts parameter is passed through to the Stream
constructor. This stream fully respect the Stream3 interface.
topic parameter is passed to the
the returned object has the following method added:
Subscribe to the given topic, which can also be an array of topics.
Unsubscribe from the given topic, which can also be an array of topics.
Close the stream, unsubscribing from all the topics.
This is aliased to
close() for backwards compatibility.