Add observable pattern to websocket server