大佬教程收集整理的这篇文章主要介绍了RxAndroid：创建简单的Hot Observable，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
private Observable createObservable() { return Observable.create ( new Observable.onSubscribe<Integer>() { @Override public void call(Subscriber<? super Integer> sub) { for (int i = 1; i < MAX_PROGRESS + 1; i++) { sub.onNext(i); SystemClock.sleep(1000); } sub.onCompleted(); } } ); }
我的理解是这是一个冷的Observable.我想要生成序列而不管任何订阅者,并且当订阅者订阅时,希望他们接收在订阅时恰好是当前的值. IOW,把它变成一个热的Observable.我宁愿不是Observable的子类,因为它将它绑定到一个具体的Integer,而在实践中,实际的类型会有所不同.
如果您的代码看起来像
Observable<T> src = ...; Subscriber<T> dst; src.subscribe(dst);
Observable<T> src = ...; BehaviorSubject<T> subject = BehaviorSubject.create(DefaultValuE); src.subscribe(subject);
立即订阅源,主题将采取与抛出的速度一样快. BehaviorSubject仅保留更新的值并删除DefaultValue&以前的所有值.
// safe to do multiple times. Subscriber<T> dst; subject.subscribe(dst);
在订阅时,dst在订阅时立即从src(或DefaultValuE)接收最新值,然后在dst取消订阅之前接收所有后续值.
警告：受试者倾向于过度使用,因此请确保您需要过度使用.
以上是大佬教程为你收集整理的RxAndroid：创建简单的Hot Observable全部内容，希望文章能够帮你解决RxAndroid：创建简单的Hot Observable所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。