摘要:我们从最简单的一段代码入手实际上方法就是返回了一个创建了一个观察者主要有方法对应的执行的逻辑是对应的是类构造参数的回调接口调用了入参是创建了一个先会调用的然后调用根据上图其实就是调用
Observableobservable = Observable.just("hello world"); Consumer consumer2 = new Consumer (){ @Override public void accept(String s) throws Exception { System.out.println("Test1" + s); } }; observable.subscribe(consumer2);
我们从最简单的一段代码入手()
Observable.just实际上just方法就是返回了一个ObservableJust
ObservableJust Observable.subscribe创建了一个LambdaObserver观察者
LambdaObserver
主要有onSubscribe,onNext,onError,onComplete方法对应的执行的逻辑是对应的是类构造参数的回调接口
调用了ObservableJust.subscribeActual入参是LambdaObserver
创建了一个ScalarDisposable
先会调用LambdaObserver的onSubscribe然后调用ScalarDisposable.run根据上图其实就是调用LambdaObserver.onNext
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/77597.html
摘要:而这个就是线程调度的关键前面的例子中我们通过指定了发射处理事件以及通知观察者的一系列操作的执行线程,正是通过这个创建了我们前面提到的。总结这一章以执行流程操作符实现以及线程调度三个方面为切入点剖析了源码。 转载请注明出处:https://zhuanlan.zhihu.com/p/22338235 RxJava系列1(简介) RxJava系列2(基本概念及使用介绍) RxJava系列3...
摘要:作用默认的,直接在当前线程运行总是开启一个新线程用于密集型任务,如异步阻塞操作,这个调度器的线程池会根据需要增长对于普通的计算任务,请使用默认是一个,很像一个有线程缓存的新线程调度器计算所使用的。这个使用的固定的线程池,大小为核数。 转载请注明出处:https://zhuanlan.zhihu.com/p/20687307 RxJava系列1(简介) RxJava系列2(基本概念及使...
阅读 2730·2021-11-02 14:42
阅读 3132·2021-10-08 10:04
阅读 1155·2019-08-30 15:55
阅读 990·2019-08-30 15:54
阅读 2283·2019-08-30 15:43
阅读 1654·2019-08-29 15:18
阅读 834·2019-08-29 11:11
阅读 2306·2019-08-26 13:52