unshift

'use strict';

var unshift = require('unshift');

unshift
  .transport('jsonp', unshift.jsonp)
  .transport('flash', unshift.flash)
  .transport('xhr', unshift.xhr)
  .transport('event-source', unshift.eventsource)
  .transport('custom', require('custom-transport'))
  .transport('websocket', unshift.websocket);

unshift.transform('incoming', function incoming(msg, next) {
  setTimeout(function timeout() {
    msg.data = 'foo';
    next(undefined, false);
  });
});

unshift.transform('incoming', 'event', function incoming(msg) {
  delete msg.data;
  return false;
});

unshift.on('event', function event(msg) {
  console.log(msg);
});

unshift.listen(8080);

If this excites you, and you want to contribute. You know where to find me.