Rx wrapper over socket.io library with Generic functions - View it on GitHub