Scuttlebutt Stream

An easier way to deal with scuttlebutt streams.

var scuttlebutt = require('scuttlebutt-stream');
var Model       = require('scuttlebutt/model');

var m1 = new Model();
var s1 = m1.createStream();

var m2 = new Model();
var s2 = m2.createStream();

var scs = scuttlebutt(function(data) {
	this.queue([ data[0], 'Foo' ]);
});

s1.pipe(scs).pipe(s2);

m1.set('name', 'Drew');

process.nextTick(function() {
	console.log(m1.get('name'), m2.get('name'));
});