8-10 ObserveableCommand演示


创建类继承HystrixObservableCommand泛型是String 重写里面方法。
8-10 ObserveableCommand演示
返回的类型就是 Observable,返回的就是它
8-10 ObserveableCommand演示
初始化name属性和构造方法
8-10 ObserveableCommand演示
这是哦我们讲隔离的时候,会用到的东西,为了减少那时候的代码量,所以这里提前做个预留,
8-10 ObserveableCommand演示
那么我们返回呢?要返回Observable<String> 要返回它肯定要创建一个对象,自带的给我们封装好了一个方法
8-10 ObserveableCommand演示

8-10 ObserveableCommand演示
后面还要做IO处理
8-10 ObserveableCommand演示
它是调用onNext方法做业务处理。
8-10 ObserveableCommand演示
也就是说它可以在业务处理里面写无数个onNext
8-10 ObserveableCommand演示
只要用onCompleted表示业务处理完成。
8-10 ObserveableCommand演示

创建测试类

8-10 ObserveableCommand演示
从CommandTest里面复制代码到我们的ObservableCommandTest里面。
8-10 ObserveableCommand演示

8-10 ObserveableCommand演示

这里创建的类型就是ObserveCommandDemo
8-10 ObserveableCommand演示
下面的代码不用动,只要加点区别就可以了
8-10 ObserveableCommand演示
执行这个测试方法
8-10 ObserveableCommand演示

8-10 ObserveableCommand演示
把这段注释掉。
8-10 ObserveableCommand演示

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

再次测试
8-10 ObserveableCommand演示
onNext执行了3次
8-10 ObserveableCommand演示
一次就只能执行一回的调用,不能执行太多次,调用完之后要重新再创建另外一个对象。
8-10 ObserveableCommand演示

结束

 

上一篇:Angular学习问题笔记 (2020.6.17)


下一篇:Python读取文件时,出现SyntaxError: (unicode error) ‘unicodeescape‘ codec can‘t decode bytes in position 2-3