Rxjava学习笔记
2018-11-01 本文已影响0人
raincxy
Rxjava2.x出现了两种观察者模式:
Observable ( 被观察者(发射器) ) / Observer ( 观察者 (接收器))
Flowable (被观察者(发射器) )/ Subscriber (观察者 (接收器))
两者的区别:
摘自:https://www.jianshu.com/p/0cd258eecf60
背压(backpressure)是指在异步场景中,被观察者发送事件速度远快于观察者的处理速度的情况下,一种告诉上游的被观察者降低发送速度的策略。(官方关于背压的讲解)
Rxjava的基本语法1:Observable.subscribe(Observer) 发射器发送事件,接收器接收事件,中间使用subscribe(订阅)关联起来。
Create 操作符应该是最常见的操作符了,主要用于产生一个 Obserable 被观察者对象,为了方便大家的认知,以后的教程中统一把被观察者 Observable 称为发射器(上游事件),观察者 Observer 称为接收器(下游事件)。
'''Observable.create(new ObservableOnSubscribe() {
'''