本文整理了Java中io.reactivex.Observable.sequenceEqual()
方法的一些代码示例,展示了Observable.sequenceEqual()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Observable.sequenceEqual()
方法的具体详情如下:
包路径:io.reactivex.Observable
类名称: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
@Test
public void test1() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.just("one", "two", "three"),
Observable.just("one", "two", "three"));
verifyResult(o, true);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void test2() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.just("one", "two", "three"),
Observable.just("one", "two", "three", "four"));
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void test3() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.just("one", "two", "three", "four"),
Observable.just("one", "two", "three"));
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void simpleInequal() {
Observable.sequenceEqual(Observable.just(1), Observable.just(2))
.test()
.assertResult(false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void test2Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.just("one", "two", "three"),
Observable.just("one", "two", "three", "four")).toObservable();
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
@Ignore("Null values not allowed")
public void testWithNull2() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.just((String) null), Observable.just((String) null));
verifyResult(o, true);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
@Ignore("Null values not allowed")
public void testWithNull1() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.just((String) null), Observable.just("one"));
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithEmpty1() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.<String> empty(),
Observable.just("one", "two", "three"));
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void simpleInequalObservable() {
Observable.sequenceEqual(Observable.just(1), Observable.just(2))
.toObservable()
.test()
.assertResult(false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
@Ignore("Null values not allowed")
public void testWithNull2Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.just((String) null), Observable.just((String) null)).toObservable();
verifyResult(o, true);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithEmpty2Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.just("one", "two", "three"),
Observable.<String> empty()).toObservable();
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithEmpty1Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.<String> empty(),
Observable.just("one", "two", "three")).toObservable();
verifyResult(o, false);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithError1() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException())),
Observable.just("one", "two", "three"));
verifyError(o);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithError1Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException())),
Observable.just("one", "two", "three")).toObservable();
verifyError(o);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithError2Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.just("one", "two", "three"),
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException()))).toObservable();
verifyError(o);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithEmpty3() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.<String> empty(), Observable.<String> empty());
verifyResult(o, true);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithError3() {
Single<Boolean> o = Observable.sequenceEqual(
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException())),
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException())));
verifyError(o);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithEmpty3Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.<String> empty(), Observable.<String> empty()).toObservable();
verifyResult(o, true);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testWithError3Observable() {
Observable<Boolean> o = Observable.sequenceEqual(
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException())),
Observable.concat(Observable.just("one"),
Observable.<String> error(new TestException()))).toObservable();
verifyError(o);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void prefetchObservable() {
Observable.sequenceEqual(Observable.range(1, 20), Observable.range(1, 20), 2)
.toObservable()
.test()
.assertResult(true);
}
内容来源于网络,如有侵权,请联系作者删除!