2018-07-14
Coding
RxJava
Java
RxJava 为我们提供了两个调度操作符subscribeOn和observeOn.
它们分别可以在订阅(subscribe)阶段和观察(observe)阶段进行线程的调度。
示例代码
2018-07-12
Coding
Lambda
Java
2018-07-11
Coding
Lambda
Java
2018-07-10
Coding
Lambda
Java
2018-05-04
Coding
RxJava
Java
继续刚才KFC的例子。
我们都知道吮指原味鸡来自于鸡的不同部位,分别有鸡腿,鸡胸和鸡肋。
现在我这个人很挑,不吃鸡肋,该怎么办呢。
最直接的想法,我们当然可以很直接在KFC(Publisher)内做判断。
但是很快我们就发现了问题
想象一条流水线,KFC是起点,我是终点,我们不应该让KFC再也不生产鸡肋,而是应该在流水线上安排一个工人(KFC服务员),由服务员来帮我们过滤鸡肋。KFC对服务员负责,服务员对我负责。
2018-05-03
Coding
RxJava
Java
Reactive-streams 是 RxJava的唯一依赖,它是一项响应式编程API标准,已被java标准库收录。
Reactive-streams只定义了4个接口共计7个方法,这7个方法构成了整个Reactive世界。
由于这些方法都太直观了没什么好说的,我就举个例子: