《Dubbo 实现原理与源码解析 —— 精品合集》 《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》 《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》 《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》 《Java 面试题 + Java 学习指南》

摘要: 原创出处 http://t.cn/EqKFO53 「一叶知秋」欢迎转载,保留摘要,谢谢!


🙂🙂🙂关注微信公众号:【芋道源码】有福利:

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言将得到认真回复。甚至不知道如何读源码也可以请教噢
  4. 新的源码解析文章实时收到通知。每周更新一篇左右
  5. 认真的源码交流微信群。

最近给小伙伴分享了Rxjava的源码解读,并录制成视频,也是为了配合自己的未来出版的书,也是对书的内容的补充,将未能写进去的内容通过视频来展现,也加入了一些自己的理解。希望可以对大家有用。

以下为视频分享内容:

01 响应式入门:https://www.bilibili.com/video/av34537840/?p=1

02 Java9中的响应式编程:https://www.bilibili.com/video/av34537840/?p=2

03 Rxjava开篇:https://www.bilibili.com/video/av34537840/?p=3

04 Rxjava中create方法的设计思想:https://www.bilibili.com/video/av34537840/?p=4

05 Observables和Observable.cache():https://www.bilibili.com/video/av34537840/?p=5

06 无休止数据流与定时控制:https://www.bilibili.com/video/av34537840/?p=6

07 Demo的设计初衷:https://www.bilibili.com/video/av34537840/?p=7

08 Observable.cache()源码解读:https://www.bilibili.com/video/av34537840/?p=8

09 ConnectableObservable与publish().refCount()解读:https://www.bilibili.com/video/av34537840/?p=9

10 SubmissionPublisher 中订阅者状态的管理:https://www.bilibili.com/video/av34537840/?p=10

11 RxJava中Subject解读:

https://www.bilibili.com/video/av34537840/?p=11

12 filter() map()深入解读与flatMap()初解:https://www.bilibili.com/video/av34537840/?p=12

13 flatMap()与scan()深入解读:https://www.bilibili.com/video/av34537840/?p=13

14 groupBy()进行分组:https://www.bilibili.com/video/av34537840/?p=14

15 merge()的源码解读 上:https://www.bilibili.com/video/av34537840/?p=15

16 merge()的源码解读 下:https://www.bilibili.com/video/av34537840/?p=16

17 zip()的源码解读:https://www.bilibili.com/video/av34537840/?p=17

18 combineLatest()的源码解读:https://www.bilibili.com/video/av34537840/?p=18

19 withLatestFrom() 源码解读:https://www.bilibili.com/video/av34537840/?p=19

20 amb() 操作源码解读:https://www.bilibili.com/video/av34537840/?p=20

21 scan()操作的2次深入:https://www.bilibili.com/video/av34537840/?p=21

22 reduce()源码解读:https://www.bilibili.com/video/av34537840/?p=22

23 collect() 源码解读:https://www.bilibili.com/video/av34537840/?p=23

24 distinct() distinctUntilChanged() compose() lift()及其他操作源码解读:https://www.bilibili.com/video/av34537840/?p=24

25 Observable实战之Spring MVC返回值的响应式化改造:https://www.bilibili.com/video/av34537840/?p=25

26 汇率查询的小服务及对于返回值处理抽取的前置知识讲解:https://www.bilibili.com/video/av34537840/?p=26

27 写一个SpringMVC的响应式返回值处理组件springboot-starter:https://www.bilibili.com/video/av34537840/?p=27

28 RxJava2中的多线程操作中调度器的引入:https://www.bilibili.com/video/av34537840/?p=28

29 subscribeOn() observeOn() unsubscribeOn()操作源码解读:https://www.bilibili.com/video/av34537840/?p=29

30 调度器Scheduler源码设计思路解读:https://www.bilibili.com/video/av34537840/?p=30

31 调度器Scheduler源码解读补充1:https://www.bilibili.com/video/av34537840/?p=31

32 调度器Scheduler源码解读补充2:https://www.bilibili.com/video/av34537840/?p=32

33 调度器Scheduler源码解读补充3:https://www.bilibili.com/video/av34537840/?p=33

34 背压回顾以及一些探究:https://www.bilibili.com/video/av34537840/?p=34

35 rxjava中SpscLinkedArrayQueue无界队列的实现解读:https://www.bilibili.com/video/av34537840/?p=35

36 从Observable到 Flowable 的设计思路 及Flowable.create() 中背压设计的解读:https://www.bilibili.com/video/av34537840/?p=36

37 onBackpressureXXX()操作与Flowable.generate()解读:https://www.bilibili.com/video/av34537840/?p=37

38 关于Rxjava解读简短的结束语:https://www.bilibili.com/video/av34537840/?p=38

文章目录