pull-redis-pubsub

Simple wrapper to get redis pub sub channels as a pull stream.

subscriber

The subscriber is a pull stream source that will emit new messages over time.

publisher

The publisher is a pull stream sink that you can pipe new messages too.

install

npm install pull-redis-pubsub

example

Publisher

var redis_pub = require('pull-redis-pubsub').pub;
var pushable  = require('pull-pushable')
var pull      = require('pull-stream')

function publisher () {
	if (! (this instanceof publisher)) return new publisher ();
	this.buffer = new pushable;
	var self    = this;
	this.emit   = function (data) {
		self.buffer.push(JSON.stringify(data));
	}
	pull(
		this.buffer,
		redis_pub('cool_channel')
	)
}

var pub = publisher ()

setInterval(function () {

	pub.emit({
		demo: Math.random() // important data
	})

}, 1000)

Subscriber

var redis_sub = require('pull-redis-pubsub').sub;
var pull      = require('pull-stream')

pull(
	redis_sub('cool_channel'),
	pull.log()
)