java. Replaced ListenableFuture with rxjava Observable, fixed #96.