receiving socket data via Rx