An Rx.js wrapper which provides a simple streaming API for building applications with socket.io. - View it on GitHub