Changed RX to subscribe on ThreadPool