Implemented RxClient.subscribe()
Added one test to test multiple servers for load balancing.