An Rx.js wrapper which provides a simple streaming API for building applications with socket.io.