A more advanced web socket wrapper for RxJS