- 综合排序
- 最热优先
- 最新优先
- 来自专栏Android开发经验分享
RxJava 之 create操作符 源码解析
T>, Disposable { ... <T>, Disposable {...} 所以调用dispose(AtomicReference<Disposable> field)方法后， isDisposed(Disposable d)即返回true。 , Disposable { ... 所以 isDisposed(Disposable d) 为 true. dispose(AtomicReference<Disposable> field) 方法中因为 current 为 null,
49830编辑于 2022-12-19 - 来自专栏HelloCode开发者学习平台
RxSwift核心逻辑——序列的产生以及订阅
描述了序列的产生、序列的订阅（绑定）、序列的操作符，以及订阅管理器Disposable（管理订阅的生命周期）。 /// 创建一个序列 let observable = Observable<String>.create { (observe) -> Disposable in /// 生产一个事件 = nil) -> Disposable { let disposable: Disposable if let disposed = onDisposed { disposable = Disposables.create(with: disposed) } } （滑动显示更多） 前面的一些Disposable管理，我们先不管，直接从 let observer = AnonymousObserver<Element> { event in 这一行代码开始看
79821编辑于 2022-01-12 - 来自专栏Android开发经验分享
Observable subscribe流程介绍
转载请以链接形式标明出处： 本文出自:103style的博客 本文基于 RxJava 2.x 版本 ---- 我们直接看Observable的subscribe方法 public final Disposable super Disposable> onSubscribe) { ... super Disposable> onSubscribe) 我们可以看到 前面四个方法都是调用了第五个方法，对参数onNext、onError、onComplete、onSubscribe的默认赋值。 > implements Observer<T>, Disposable, LambdaConsumerIntrospection { final Consumer<? super Disposable> onSubscribe; public LambdaObserver(Consumer<? super T> onNext, Consumer<?
53710编辑于 2022-12-19 - 来自专栏andy的小窝
关于Rxjava2下的RxBus实现
* @param o * @param disposable */ public void addSubscription(Object o, Disposable disposable) { if (mSubscriptionMap == null) { mSubscriptionMap = new HashMap<>() = null) { mSubscriptionMap.get(key).add(disposable); } else { //一次性容器 CompositeDisposable disposables = new CompositeDisposable(); disposables.add(disposable); disposable = rxBus.doSubscribe(eventType, action, new Consumer<Throwable>() { @Override
1.7K20发布于 2020-02-12 - 来自专栏青蛙要fly的专栏
Android技能树 — Rxjava取消订阅小结(1):自带方式
而RxJava2换了方式，但是基本方法是一模一样的,只是换成了Disposable： 如果我们使用的是Consumer，那和原来RxJava 1 是一样的操作： Disposable disposable disposable.isDisposed()){ disposable.dispose(); } 复制代码 但是我们可能更多的是使用Observer等，那这时候subscrbe(observer )返回的是void,所以不能像上面一样操作，需要下面代码所示那样： private Disposable disposable; Observable.just(1).subscribe(new Observer <Integer>() { @Override public void onSubscribe(Disposable d) { disposable disposable.isDisposed()){ disposable.dispose(); } 复制代码 和RxJava 1 最大的区别主要是获取这个取消订阅对象的地方不同，Disposable
1.5K30发布于 2018-08-29 - 来自专栏JetPack
RxJava奇淫技巧-实现倒计时的功能
(new Observer<String>() { @Override public void onSubscribe(Disposable d) { disposable = d; } @Override disposable.isDisposed()) { Log.e("demo", "关闭"); disposable.dispose(); disposable = null; } } 其实上面的写法我们还可以更进一步简略： //简略写法,是不是特别简单 private void startTimer(long time ,int count) { disposable = Observable.timer(time, TimeUnit.MILLISECONDS) .take
1K10编辑于 2022-02-09 - 来自专栏iOS开发干货分享
RxSwift销毁者-dispose源码解析
上面代码跟进去看到BinaryDisposable(disposable1, disposable2) 原来创建的二元销毁者！ _disposable1?.dispose() self._disposable2?.dispose() self. _disposable1 = nil self. _disposable2 = nil } } 二元销毁者的 dispose 方法也在预料之中，分别销毁 那么我们的重点就应该探索，在 subscribe 这里面创建的关键销毁者是什么? , subscription: Disposable) { self.
1.3K30发布于 2019-08-09 - 来自专栏菩提树下的杨过
RxJava2学习笔记(1)
observer1 = new Observer<String>() { @Override public void onSubscribe(@NonNull Disposable subscribe(new Observer<String>() { @Override public void onSubscribe(@NonNull Disposable onComplete() { System.out.println("complete"); } }); 输出： subscribe=> a error:/ by zero 1.4 disposable 准备发送c"); emitter.onNext("c"); emitter.onComplete(); }).subscribe(new Observer<String>() { Disposable disposable; @Override public void onSubscribe(@NonNull Disposable d) { disposable =
86990发布于 2018-03-28 - 来自专栏Android-薛之涛
Android-RxJava(下)
}).subscribe(new Observer<Integer>() { @Override public void onSubscribe(Disposable >() { @Override public void accept(Disposable disposable) throws Exception { mDisposable; @Override public void onSubscribe(Disposable d) { >() { @Override public void accept(Disposable disposable) throws Exception { doOnSubscribe Observable 每发送 onSubscribe() 之前都会回调这个方法 doOnDispose 当调用 Disposable 的 dispose() 之后回调该方法
1.1K30发布于 2019-07-15 - 来自专栏Android开发经验分享
RxJava之timer和interval操作符源码解析
通过scheduler.scheduleDirect(ios, delay, unit) 返回一个 Disposable 对象。 > implements Disposable, Runnable { final Observer<? d) { DisposableHelper.trySet(this, d); } } 首先看 TimerObserver 的 setResource(Disposable d) , Disposable d) { if (! > implements Disposable, Runnable { final Observer<?
94120编辑于 2022-12-19 - 来自专栏三流程序员的挣扎
RxJava Observable 使用和源码阅读
dispose() // 解除订阅 } override fun onSubscribe(d: Disposable) { disposable = d } // 订阅 observable.subscribe 比如 // accept 依次收到被观察者发过来的 a 和 b val disposable: Disposable = Observable.fromArray("a","b").subscribe( { textView.text = "${textView.text}\n $it " }) 此时方法返回值是 Disposable 对象，可用于解除订阅。 ，可用于解除订阅，然后立刻调用 observer.onSubscribe，这样外面的观察者第一个执行到的回调就是 onSubscribe，并且拿到了 Disposable 对象。 T>, Disposable { ...
98110发布于 2018-09-11 - 来自专栏刘晓杰
源码阅读--RxJava（二）
static class PeriodicDirectTask implements Runnable, Disposable static final class DisposeTask implements Runnable, Disposable 大体的调度流程如下： 1.createWorker（这是个abstract方法，需要自己实现） 2.RxJavaPlugins.onSchedule （interface）—-ReferenceDisposable—–io.reactivex.disposables中的其他Disposable 通过Disposables来管理。 Disposables通过调用fromXXX来生成对应的Disposable Disposable中dispose方法的具体实现：(说白了就是设置的一种状态) public final void > implements ObservableEmitter<T>, Disposable { final Observer<?
78520发布于 2019-02-21 - 来自专栏三流程序员的挣扎
RxJava 辅助操作符
lateinit var disposable : Disposable // 第一个参数提供了一个集合资源 Observable.using({ listOf(1,2,3,4,5,6,7,8) }, ) { disposable = d} override fun onNext(t: Int) { Log.e("RX", "onNext $t ") if (t == 5) disposable?. super T> onNext) public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Disposable> onSubscribe) public final void subscribe(Observer<?
2.7K20发布于 2018-09-11 - 来自专栏被删的前端游乐场
VSCode 源码解读：事件系统设计
_register(new Emitter<T>())这样的方式注册事件发射器，我们能看到该方法继承自Disposable。 而Disposable的实现也很简洁:export abstract class Disposable implements IDisposable { // 用一个 Set 来存储注册的事件发射器private ) === this) {throw new Error('Cannot register a disposable on itself!') _store.add(t);}}也就是说，每个继承Disposable类都会有管理事件发射器的相关方法，包括添加、销毁处理等。 ，并将其标记为已处置 // 将来添加到此对象的所有 Disposable 都将在 add 中处置。
961101编辑于 2024-07-23 - 来自专栏program
Android RxJava的使用
observer = new Observer<String>() { @Override public void onSubscribe(@NonNull Disposable world").subscribe(new Observer<String>() { @Override public void onSubscribe(Disposable .subscribe(new Observer<List<String>>() { @Override public void onSubscribe(Disposable subscribe(new Observer<Long>() { @Override public void onSubscribe(@NonNull Disposable , 20).subscribe(new Observer<Integer>() { @Override public void onSubscribe(Disposable
3.6K20编辑于 2022-06-29 - 来自专栏安卓开发干货分享
RxJava这么好用却容易内存泄漏？解决办法是...
一般的做法是订阅成功后，拿到Disposable对象，在Activity/Fragment销毁时,调用Disposable对象的dispose()方法，将异步任务中断，也就是中断RxJava的管道，代码如下 ： Disposable disposable = Observable .interval(0, 1, TimeUnit.SECONDS) //开启一个定时器 disposable.isDisposed()) { disposable.dispose(); } 这种做法在代码的执行效率上是最高效 对象，然后在某个时机，调用该对象的Disposable.dispose()方法中断管道，以达到目的。 RxHttp 内部只有一个业务逻辑的管道，通过自定义观察者，拿到Disposable对象，暴露给Scope接口，Scope的实现者就可以在合适的时机调用Disposable.dispose()方法中断管道
5K20发布于 2019-07-04 - 来自专栏Android开发经验分享
Flowable subscribe流程介绍
转载请以链接形式标明出处： 本文出自:103style的博客 Flowable 的 subscribe 方法 public final Disposable subscribe() { Functions.ON_ERROR_MISSING, Functions.EMPTY_ACTION, FlowableInternalHelper.RequestMax.INSTANCE); } public final Disposable Functions.ON_ERROR_MISSING, Functions.EMPTY_ACTION, FlowableInternalHelper.RequestMax.INSTANCE); } public final Disposable onError, Functions.EMPTY_ACTION, FlowableInternalHelper.RequestMax.INSTANCE); } public final Disposable onNext, onError, onComplete, FlowableInternalHelper.RequestMax.INSTANCE); } public final Disposable
55310编辑于 2022-12-19 - 来自专栏程序那些事
响应式编程简介之:Reactor
再看看Flux的subscribe方法： Disposable subscribe(); Disposable subscribe(Consumer<? 上面所有的subscribe方法，都会返回一个Disposable对象，我们可以通过Disposable对象的dispose()方法，来取消这个subscribe。 Disposable只定义了两个方法： public interface Disposable { void dispose(); default boolean isDisposed 有了Disposable，当然要介绍它的工具类Disposables。 Disposables.swap() 可以创建一个Disposable，用来替换或者取消一个现有的Disposable。 Disposables.composite(…)可以将多个Disposable合并起来，在后面统一做处理。
1.7K41发布于 2020-11-11 - 来自专栏Android 进阶
RxJava2 解析
.subscribe(new Observer<String>() { @Override public void onSubscribe(Disposable 对象释放 public static boolean dispose(AtomicReference<Disposable> field) { Disposable current = field.get(); Disposable d = DISPOSED; if (current ! > implements Observer<T>, Disposable { private static final long serialVersionUID <Disposable> s; SubscribeOnObserver(Observer<?
1.5K10发布于 2019-12-26 - 来自专栏Android相关
RxJava2--基本使用
${Thread.currentThread().name}") override fun onSubscribe(d: Disposable?) ${Thread.currentThread().name}...Disposable:$d") override fun onNext(value: Int?) super T> observer) public final Disposable subscribe(Consumer<? super T> onNext) public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) public final Disposable subscribe(Consumer<?
1.7K20发布于 2018-12-28
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号