streamchat-browser.js

var shoe = require('shoe');
var through = require('through');

var result = document.getElementById('result');

var stream = shoe('/chat');

stream.on( 'data', function( msg ){
	console.log( 'data', msg );
});

say = function( message ){
	stream.write( message );
};

streamchat-server.js

var shoe = require('shoe');
var http = require('http');

var ecstatic = require('ecstatic')(__dirname + '/assets');

var server = http.createServer(ecstatic);
server.listen(9999);

var Stream = require('stream');

// create a single chat stream all streams talk to
var chat_stream = new Stream.Duplex;
chat_stream._read = function(){
};
chat_stream._write = function( chunk, encoding, next ){
	this.push( chunk );
	next();
};

var sock = shoe( function ( stream ){
	stream.pipe( chat_stream );
	chat_stream.pipe( stream );
});
sock.install( server, '/chat' );