创建类继承HystrixObservableCommand泛型是String 重写里面方法。

返回的类型就是 Observable，返回的就是它

初始化name属性和构造方法

这是哦我们讲隔离的时候，会用到的东西，为了减少那时候的代码量，所以这里提前做个预留，

那么我们返回呢？要返回Observable<String> 要返回它肯定要创建一个对象，自带的给我们封装好了一个方法



后面还要做IO处理

它是调用onNext方法做业务处理。

也就是说它可以在业务处理里面写无数个onNext

只要用onCompleted表示业务处理完成。

创建测试类

从CommandTest里面复制代码到我们的ObservableCommandTest里面。




这里创建的类型就是ObserveCommandDemo

下面的代码不用动，只要加点区别就可以了

执行这个测试方法



把这段注释掉。



注释掉就有点尴尬，下面就要休眠，因为主线程不能退出的太快。刚才的错误就是意思 Command用了太多回了。


再次测试

onNext执行了3次

一次就只能执行一回的调用，不能执行太多次，调用完之后要重新再创建另外一个对象。

结束

8-10 ObserveableCommand演示

原文：https://www.cnblogs.com/wangjunwei/p/12812495.html