a spike to make RxJS and Socket.io work together