var peristream = require('peristream');
 
var stream = peristream(urlOrId);
 
stream.connect().then(function(emitter){
  emitter.on(peristream.ALL, function(message){
    // ...
  });
 
  emitter.on(peristream.HEARTS, function(message){
    // ...
  });
 
  emitter.on(peristream.COMMENTS, function(message){
    // ...
  });
 
  emitter.on(peristream.DISCONNECT, function(message){
    // ...
  });
 
});
 
// eventually...
stream.disconnect();