下面，使用 Proxy 写一个观察者模式的最简单实现，即实现observable和observe这两个函数。思路是observable函数返回一个原始对象的 Proxy 代理，拦截赋值操作，触发充当观察者的各个函数。 上面代码中，先定义了一个Set集合，所有观察者函数都放进这个集合。然后，obser ...
分类：
其他好文 时间：
2018-01-01 17:02:12
阅读次数：
164
AbstractCommand有两种种调用方式，分别是observe,toObservable toObservable是hystrix创建的一个Observable，当向这个Observable监听时，它会执行run命令，并返回消息。 具体流程可以参见：hystrix源码之AbstractComm ...
分类：
其他好文 时间：
2017-12-18 19:00:06
阅读次数：
179
RxAndroid 响应式编程 类似于监听-观察者模式 在观察者模式中，你的对象需要实现 RxJava 中的两个关键接口：Observable 和 Observer。当 Observable 的状态改变时，所有的订阅它的 Observer 对象都会被通知。 在 Observable 接口的众多方法中 ...
分类：
移动开发 时间：
2017-12-15 18:56:47
阅读次数：
258
一：初上手(填坑) Observable将事件序列执行完毕后，会回调Observe的onNext()方法和onCompleted()方法，当出现异常/错误时会调用onError()方法。 由此，我们推断，问题出现的地方应该是在Observable的执行过程。 先阐述一下笔者的需求，使用retrofi ...
分类：
编程语言 时间：
2017-12-11 22:07:50
阅读次数：
232
观察者模式是Java非常重要的一个设计模式。对于观察者模式，JDK已经为我们提供了对应的接口和类。 分别是观察者Observer，观察者也成为订阅者Subscribe， JDK代码为： Java源码考虑比较周到的。首先，使用Vector，Vector相比于ArrayList来说，它是线程安全的。其次 ...
分类：
其他好文 时间：
2017-12-10 20:14:29
阅读次数：
155
1.响应式编程 例子import {Observable} from "rxjs/Observable"; Observable.from([1,2,3,4]) .filter((item)=>item%2==0) .map(e=>e*e) .subscribe( e=>console.log(e) ...
分类：
其他好文 时间：
2017-12-10 11:12:01
阅读次数：
116
内容为整理博主文章： "https://juejin.im/user/58870f04128fe10065efc8d9/article" 个人觉得他对Operators的解说较容易理解和全面，顾把它们整理在一起，也方面查找。 Operators： Observable 的 Operators 是实例 ...
分类：
其他好文 时间：
2017-12-02 19:15:10
阅读次数：
191
在NiceFish项目中，数据请求处理并没有用Promise的那一套方法，用的是Observable(观察者模式)，我将其理解成生产者和消费者模式 如下简单例子：出自(https://segmentfault.com/a/1190000005051034) 运行结果如下： observer.comp ...
分类：
其他好文 时间：
2017-11-27 20:04:00
阅读次数：
167
1.观察者（observer）--订阅者 update 2.被观察者(observable)--发布者 必要条件： 设置状态发生变化，然后根据变化进行通知notify 主函数： 测试结果： ...
分类：
其他好文 时间：
2017-11-12 14:52:12
阅读次数：
177
With redux-observable, we have the power of RxJS at our disposal - this means tasks that would otherwise be complicated and imperative, become simple ...
分类：
Web程序 时间：
2017-10-16 02:15:30
阅读次数：
199
