0.2.0 • Published 11 years ago
subscribe-stream v0.2.0
subscribe-stream
A simple Readable object stream that consumes the data published to
a specific redis
pub/sub channel using node_redis
.
note: We assume that it is a stringified json object coming through the pub/sub channel that is again parsed into an object because they are much nicer to deal with.
Example
var redis = require('redis'),
subscribeStream = require('../');
var stream = subscribeStream({ subscription: 'hithere' });
var client = redis.createClient();
var testObj = {
test: 'value',
other: 'otherValue'
};
stream.on('readable', function () {
var obj = stream.read();
console.log('obj', obj);
});
client.publish('hithere', JSON.stringify(testObj));
Test
npm test
License
MIT