title: How to use RxJs with Socket.IO on event
body: <p>I want to use RxJS inside of my <code>socket.on('sense',function(data){});</code>. I am stuck and confused with very few documentation available and my lack of understanding RxJS. Here is my problem. </p>
  
  <p>I have a <code>distSensor.js</code> that has a function pingEnd() </p>
  
  <pre><code>function pingEnd(x){
  socket.emit("sense", dist); //pingEnd is fired when an Interrupt is generated.
  }
  </code></pre>
  
  <p>Inside my App.js I have</p>
  
  <pre><code>io.on('connection', function (socket) {
      socket.on('sense', function (data) {
          //console.log('sense from App4 was called ' + data);
      });
  });
  </code></pre>
  
  <p>The sense function gets lots of sensor data which I want to filter using RxJS and I don't know what should I do next to use RxJs here. Any pointers to right docs or sample would help. </p>