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

Single.unsubscribeOn介绍

[英]Returns a Single which makes sure when a SingleObserver disposes the Disposable, that call is propagated up on the specified scheduler. Scheduler: unsubscribeOn calls dispose() of the upstream on the Scheduler you specify.
[中]返回一个SingleObserver，确保当SingleObserver处理一次性调用时，该调用会传播到指定的调度程序上。Scheduler:unsubscribeOn调用dispose（），在指定的计划程序上处理上游。

代码示例

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

@Override
  public SingleSource<Object> apply(Single<Object> v) throws Exception {
    return v.unsubscribeOn(Schedulers.single());
  }
});

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

@Test
public void dispose() {
  TestHelper.checkDisposed(Single.just(1)
  .unsubscribeOn(Schedulers.single()));
}

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

@Test
public void just() {
  Single.just(1)
  .unsubscribeOn(Schedulers.single())
  .test()
  .assertResult(1);
}

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

@Test
public void normal() throws Exception {
  PublishProcessor<Integer> pp = PublishProcessor.create();
  final String[] name = { null };
  final CountDownLatch cdl = new CountDownLatch(1);
  pp.doOnCancel(new Action() {
    @Override
    public void run() throws Exception {
      name[0] = Thread.currentThread().getName();
      cdl.countDown();
    }
  })
  .single(-99)
  .unsubscribeOn(Schedulers.single())
  .test(true)
  ;
  assertTrue(cdl.await(5, TimeUnit.SECONDS));
  int times = 10;
  while (times-- > 0 && pp.hasSubscribers()) {
    Thread.sleep(100);
  }
  assertFalse(pp.hasSubscribers());
  assertNotEquals(Thread.currentThread().getName(), name[0]);
}

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

pp.single(-99).unsubscribeOn(Schedulers.computation())
.subscribe(new SingleObserver<Integer>() {
  @Override

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

@Test
public void error() {
  Single.<Integer>error(new TestException())
  .unsubscribeOn(Schedulers.single())
  .test()
  .assertFailure(TestException.class);
}

代码示例来源：origin: forkachild/reel-search-android

public static <U> SingleTransformer<U, U> composeSingle() {
  return upstream -> upstream
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .unsubscribeOn(Schedulers.io());
}