大佬教程收集整理的这篇文章主要介绍了android使用RxJava实现预加载,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
在上一篇文章中介绍了使用非RxJava环境下,使用Handler机制SyncBarrier的特性实现预加载功能的方法。
在RxJava的环境下使用BehaviorSubject的特性来实现也是很方便的。
BehaviorSubject内部会缓存消息流中最近的一个消息,在后续有Subscriber订阅时,会直接将缓存的消息发送给Subscriber。
RxPreLoader.java封装如下:
import android.support.Annotation.NonNull; import java.util.LinkedList; import rx.observable; import rx.observer; import rx.Subscriber; import rx.Subscription; import rx.android.schedulers.Androidschedulers; import rx.functions.Action1; import rx.schedulers.schedulers; import rx.subjects.behaviorSubject; /** * 预加载 * preLoader = RxPreLoader.preLoad(observablE); * preLoader.get(observer1); * preLoader.get(observer2); * preLoader.reload(); * preLoader.destroy() * * @author billy.qi */ public class RxPreLoader<T> { private BehaviorSubject<T> subject; private Observable<T> observable; private Subscription subscription; private final LinkedList<Subscription> allObserver = new LinkedList<>(); private RxPreLoader(Observable<T> observablE) { //注意的是由于onCompleted也是数据流中的一个 //如果直接observer.subscribeOn(schedulers.io()).subscribe(subject); //会导致subject只能缓存onCompleted //所以此处新建一个OnSubscribe,通过调用subject.onNext(t)的方式来缓存数据 this.observable = observable; subject = BehaviorSubject.create(); subscription = Observable.create(new Observable.onSubscribe<T>() { @Override public void call(Subscriber<? super T> subscriber) { performLoad(); } }) .subscribeOn(schedulers.io()) .subscribe(subject); } public static <R> RxPreLoader<R> preLoad(@NonNull Observable<R> observablE) { return new RxPreLoader<R>(observablE); } public void reload() { performLoad(); } public Subscription get(Observer<T> observer) { Subscription subscription = subject.observeOn(Androidschedulers.mainThread()) .subscribe(observer); allObserver.add(subscription); return subscription; } private void performLoad() { observable.subscribeOn(schedulers.io()) .subscribe(new Action1<T>() { @Override public void call(T t) { if (subject != null) { subject.onNext(t); } } },new Action1<Throwable>() { @Override public void call(Throwable throwablE) { throwable.printStackTrace(); } }); } public void destroy() { synchronized (allObserver) { while(!allObserver.isEmpty()) { unsubscribe(allObserver.removeFirst()); } } unsubscribe(subscription); subscription = null; subject = null; } private void unsubscribe(Subscription subscription) { if (subscription != null && !subscription.isUnsubscribed()) { subscription.unsubscribe(); } } }
在activity中使用:
import android.os.bundle; import android.support.v7.app.AppCompatActivity; import android.widget.TextView; import java.util.concurrent.TimeUnit; import rx.observable; import rx.Subscriber; /** * 使用RxJava实现的预加载方式 */ public class RxPreLoaderActivity extends AppCompatActivity { private TextView textView; private RxPreLoader<String> preLoader; @Override protected void onCreate(Bundle savedInstanceStatE) { preLoad();//启动预加载 initLayout(savedInstanceStatE); preLoader.get(observer);//展示预加载的数据 } //初始化布局 private void initLayout(Bundle savedInstanceStatE) { super.onCreate(savedInstanceStatE); setContentView(R.layout.activity_main); settitle("使用RxPreLoader"); //通过循环多次findById来模拟复杂页面布局初始化的耗时 textView = (TextView)findViewById(R.id.textView); } //展示预加载的数据 Subscriber<String> observer = new Subscriber<String>() { @Override public void onCompleted() { } @Override public void onError(Throwable E) { e.printStackTrace(); } @Override public void onNext(String s) { textView.setText(s); } }; private void preLoad() { preLoader = RxPreLoader.preLoad(Observable.just("result").delay(500,TimeUnit.MILLISECONDS)); } @Override protected void onDestroy() { super.onDestroy(); preLoader.destroy();//销毁 } }
最后,附上源码:http://xiazai.code.net/201701/yuanma/RxPreLoader(code.net).rar
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程小技巧。
以上是大佬教程为你收集整理的android使用RxJava实现预加载全部内容,希望文章能够帮你解决android使用RxJava实现预加载所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。