让一个可连接的Observable行为像普通的Observable
可连接的Observable (connectable Observable)与普通的Observable差不多,不过它并不会在被订阅时开始发射数据,而是直到使用了Connect操作符时才会开始。用这种方法,你可以在任何时候让一个Observable开始发射数据。
Connect
RefCount操作符把从一个可连接的Observable连接和断开的过程自动化了。它操作一个可连接的Observable,返回一个普通的Observable。当第一个订阅者订阅这个Observable时,RefCount连接到下层的可连接Observable。RefCount跟踪有多少个观察者订阅它,直到最后一个观察者完成才断开与下层可连接Observable的连接。
RefCount
RxJava中的实现为refCount,还有一个操作符叫share,它的作用等价于对一个Observable同时应用publish和refCount操作。
refCount
share
publish
Copyright© 2013-2020
All Rights Reserved 京ICP备2023019179号-8