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. This can be seen in the example below.
This makes it especially useful for consuming godot
data sent using the redis
reactor.
Example
var redis = subscribeStream = ; var stream = ; var client = redis; var testObj = test: 'value' other: 'otherValue'; stream; client;
Which outputs:
obj { test: 'value', other: 'otherValue' }
Test
npm test
License
MIT