io.reactivex.Single.onTerminateDetach()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(1.2k)|赞(0)|评价(0)|浏览(267)

本文整理了Java中io.reactivex.Single.onTerminateDetach()方法的一些代码示例,展示了Single.onTerminateDetach()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Single.onTerminateDetach()方法的具体详情如下:
包路径:io.reactivex.Single
类名称:Single
方法名:onTerminateDetach

Single.onTerminateDetach介绍

[英]Nulls out references to the upstream producer and downstream SingleObserver if the sequence is terminated or downstream calls dispose(). Scheduler: onTerminateDetach does not operate by default on a particular Scheduler.
[中]如果序列被终止或下游调用dispose(),则清空对上游生产者和下游SingleObserver的引用。调度器:默认情况下,onTerminateDetach不会在特定的调度器上运行。

代码示例

代码示例来源:origin: ReactiveX/RxJava

@Override
  public SingleSource<Object> apply(Single<Object> m) throws Exception {
    return m.onTerminateDetach();
  }
});

代码示例来源:origin: ReactiveX/RxJava

@Test
public void onSuccess() {
  Single.just(1)
  .onTerminateDetach()
  .test()
  .assertResult(1);
}

代码示例来源:origin: ReactiveX/RxJava

@Test
public void dispose() {
  TestHelper.checkDisposed(PublishProcessor.create().singleOrError().onTerminateDetach());
}

代码示例来源:origin: ReactiveX/RxJava

@Test
public void onError() {
  Single.error(new TestException())
  .onTerminateDetach()
  .test()
  .assertFailure(TestException.class);
}

代码示例来源:origin: akarnokd/akarnokd-misc

.onTerminateDetach()
.subscribe(to);

相关文章

微信公众号

最新文章

更多