io.reactivex.Observable.sequenceEqual()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(156)

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

Observable.sequenceEqual介绍

[英]Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the same by comparing the items emitted by each ObservableSource pairwise.

Scheduler: sequenceEqual does not operate by default on a particular Scheduler.
[中]返回一个单一值,该值发出一个布尔值,通过比较每个ObservableSource成对发出的项来指示两个ObservableSource序列是否相同。
Scheduler:sequenceEqual默认情况下不会在特定的计划程序上运行。

代码示例

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

  1. @Test
  2. public void test1() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.just("one", "two", "three"),
  5. Observable.just("one", "two", "three"));
  6. verifyResult(o, true);
  7. }

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

  1. @Test
  2. public void test2() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.just("one", "two", "three"),
  5. Observable.just("one", "two", "three", "four"));
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. public void test3() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.just("one", "two", "three", "four"),
  5. Observable.just("one", "two", "three"));
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. public void simpleInequal() {
  3. Observable.sequenceEqual(Observable.just(1), Observable.just(2))
  4. .test()
  5. .assertResult(false);
  6. }

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

  1. @Test
  2. public void test2Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.just("one", "two", "three"),
  5. Observable.just("one", "two", "three", "four")).toObservable();
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. @Ignore("Null values not allowed")
  3. public void testWithNull2() {
  4. Single<Boolean> o = Observable.sequenceEqual(
  5. Observable.just((String) null), Observable.just((String) null));
  6. verifyResult(o, true);
  7. }

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

  1. @Test
  2. @Ignore("Null values not allowed")
  3. public void testWithNull1() {
  4. Single<Boolean> o = Observable.sequenceEqual(
  5. Observable.just((String) null), Observable.just("one"));
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. public void testWithEmpty1() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.<String> empty(),
  5. Observable.just("one", "two", "three"));
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. public void simpleInequalObservable() {
  3. Observable.sequenceEqual(Observable.just(1), Observable.just(2))
  4. .toObservable()
  5. .test()
  6. .assertResult(false);
  7. }

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

  1. @Test
  2. @Ignore("Null values not allowed")
  3. public void testWithNull2Observable() {
  4. Observable<Boolean> o = Observable.sequenceEqual(
  5. Observable.just((String) null), Observable.just((String) null)).toObservable();
  6. verifyResult(o, true);
  7. }

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

  1. @Test
  2. public void testWithEmpty2Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.just("one", "two", "three"),
  5. Observable.<String> empty()).toObservable();
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. public void testWithEmpty1Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.<String> empty(),
  5. Observable.just("one", "two", "three")).toObservable();
  6. verifyResult(o, false);
  7. }

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

  1. @Test
  2. public void testWithError1() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.concat(Observable.just("one"),
  5. Observable.<String> error(new TestException())),
  6. Observable.just("one", "two", "three"));
  7. verifyError(o);
  8. }

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

  1. @Test
  2. public void testWithError1Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.concat(Observable.just("one"),
  5. Observable.<String> error(new TestException())),
  6. Observable.just("one", "two", "three")).toObservable();
  7. verifyError(o);
  8. }

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

  1. @Test
  2. public void testWithError2Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.just("one", "two", "three"),
  5. Observable.concat(Observable.just("one"),
  6. Observable.<String> error(new TestException()))).toObservable();
  7. verifyError(o);
  8. }

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

  1. @Test
  2. public void testWithEmpty3() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.<String> empty(), Observable.<String> empty());
  5. verifyResult(o, true);
  6. }

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

  1. @Test
  2. public void testWithError3() {
  3. Single<Boolean> o = Observable.sequenceEqual(
  4. Observable.concat(Observable.just("one"),
  5. Observable.<String> error(new TestException())),
  6. Observable.concat(Observable.just("one"),
  7. Observable.<String> error(new TestException())));
  8. verifyError(o);
  9. }

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

  1. @Test
  2. public void testWithEmpty3Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.<String> empty(), Observable.<String> empty()).toObservable();
  5. verifyResult(o, true);
  6. }

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

  1. @Test
  2. public void testWithError3Observable() {
  3. Observable<Boolean> o = Observable.sequenceEqual(
  4. Observable.concat(Observable.just("one"),
  5. Observable.<String> error(new TestException())),
  6. Observable.concat(Observable.just("one"),
  7. Observable.<String> error(new TestException()))).toObservable();
  8. verifyError(o);
  9. }

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

  1. @Test
  2. public void prefetchObservable() {
  3. Observable.sequenceEqual(Observable.range(1, 20), Observable.range(1, 20), 2)
  4. .toObservable()
  5. .test()
  6. .assertResult(true);
  7. }

相关文章

Observable类方法