Using RxJava to monitor Hystrix stream