android使用RxJava实现预加载

在上一篇文章中介绍了使用非RxJava环境下,使用Handler机制SyncBarrier的特性实现预加载功能的方法。 在RxJava的环境下使用BehaviorSubject的特性来实现也是很方便的。 BehaviorSubject内部会缓存消息流中最近的一个消息, 在后续有Subscriber订阅时,会直接将缓存的消息发送给Subscriber。 RxPreLoader.java封装如下: import android.support.annotation.NonNull; import java.util.LinkedList; import rx.Observable; impor