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

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

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

Single.equals介绍

[英]Compares two SingleSources and emits true if they emit the same value (compared via Object.equals). Scheduler: equals does not operate by default on a particular Scheduler.
[中]比较两个单一源,如果它们发出相同的值(通过Object.equals进行比较),则发出true。调度器:默认情况下,equals不会在特定的调度器上运行。

代码示例

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

@Test(expected = NullPointerException.class)
public void equalsFirstNull() {
  Single.equals(null, just1);
}

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

@Test(expected = NullPointerException.class)
public void equalsSecondNull() {
  Single.equals(just1, null);
}

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

@Test
public void equals() {
  Single.equals(Single.just(1), Single.just(1).hide())
  .test()
  .assertResult(true);
  Single.equals(Single.just(1), Single.just(2))
  .test()
  .assertResult(false);
}

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

@Test
  public void bothError() {
    List<Throwable> errors = TestHelper.trackPluginErrors();
    try {
      Single.equals(Single.error(new TestException("One")), Single.error(new TestException("Two")))
      .test()
      .assertFailureAndMessage(TestException.class, "One");

      TestHelper.assertUndeliverable(errors, 0, TestException.class, "Two");
    } finally {
      RxJavaPlugins.reset();
    }
  }
}

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

@Test
public void single() {
  SingleSubject<Integer> pp1 = SingleSubject.create();
  SingleSubject<Integer> pp2 = SingleSubject.create();
  Single.equals(pp1, pp2)
  .test()
  .cancel();
  Assert.assertFalse(pp1.hasObservers());
  Assert.assertFalse(pp2.hasObservers());
}

相关文章

微信公众号

最新文章

更多