var Reiki = require('../../index.js');
var r = new Reiki(8080);
 
// Create an event stream which sends out an event whenever any socket connected
// has received the newmessage event.
var messageStream = r.createEventStream('newMessage');
 
// Observe the message event stream and specify the function to be invoked.
messageStream.subscribe(function(data) {
    // Data contains a socket and message property.
    data.socket.broadcast.emit('newMessage', data.message);
});
 

 
### createEventStream(eventName)
 
Returns a subject event stream which broadcasts events for each independant socket connection.
 
```js
 
var r = new Reiki(8080);
var messageStream = r.createEventStream('messages');
 
messageStream.subscribe(function(data) {
    console.log(data.message);
});