RxJS Extension to connect to an API that supports socket.io