本文整理了Java中io.reactivex.Observable.mergeWith()
方法的一些代码示例,展示了Observable.mergeWith()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Observable.mergeWith()
方法的具体详情如下:
包路径:io.reactivex.Observable
类名称:Observable
方法名:mergeWith
[英]Relays the items of this Observable and completes only when the other CompletableSource completes as well.
Scheduler: mergeWith does not operate by default on a particular Scheduler.
[中]中继此可观察项,仅当其他CompletableSource也完成时才完成。
调度程序:默认情况下,mergeWith不会在特定调度程序上运行。
代码示例来源:origin: ReactiveX/RxJava
@Override
public Observable<Object> apply(Observable<Object> f)
throws Exception {
return f.mergeWith(Maybe.just(1));
}
}
代码示例来源:origin: ReactiveX/RxJava
@Override
public Observable<Object> apply(Observable<Object> f)
throws Exception {
return f.mergeWith(Single.just(1));
}
}
代码示例来源:origin: ReactiveX/RxJava
@Test(expected = NullPointerException.class)
public void mergeWithNull() {
just1.mergeWith((ObservableSource<Integer>)null);
}
代码示例来源:origin: ReactiveX/RxJava
@Override
public Observable<String> apply(final String s) {
return Observable.just(s)
.mergeWith(Observable.interval(10, TimeUnit.MILLISECONDS)
.map(new Function<Long, String>() {
@Override
public String apply(Long i) {
return s + " " + i;
}
})).take(250);
}
})
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testMergeWith() {
TestObserver<Integer> to = new TestObserver<Integer>();
Observable.just(1).mergeWith(Observable.just(2)).subscribe(to);
to.assertValues(1, 2);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void normal() {
final TestObserver<Integer> to = new TestObserver<Integer>();
Observable.range(1, 5).mergeWith(
Completable.fromAction(new Action() {
@Override
public void run() throws Exception {
to.onNext(100);
}
})
)
.subscribe(to);
to.assertResult(1, 2, 3, 4, 5, 100);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void take() {
final TestObserver<Integer> to = new TestObserver<Integer>();
Observable.range(1, 5).mergeWith(
Completable.complete()
)
.take(3)
.subscribe(to);
to.assertResult(1, 2, 3);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void normal() {
Observable.range(1, 5)
.mergeWith(Single.just(100))
.test()
.assertResult(1, 2, 3, 4, 5, 100);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void normal() {
Observable.range(1, 5)
.mergeWith(Maybe.just(100))
.test()
.assertResult(1, 2, 3, 4, 5, 100);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void emptyOther() {
Observable.range(1, 5)
.mergeWith(Maybe.<Integer>empty())
.test()
.assertResult(1, 2, 3, 4, 5);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void mainError() {
Observable.error(new TestException())
.mergeWith(Completable.complete())
.test()
.assertFailure(TestException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void normalLong() {
Observable.range(1, 512)
.mergeWith(Single.just(100))
.test()
.assertValueCount(513)
.assertComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void normalLong() {
Observable.range(1, 512)
.mergeWith(Maybe.just(100))
.test()
.assertValueCount(513)
.assertComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void mainError() {
Observable.error(new TestException())
.mergeWith(Single.just(100))
.test()
.assertFailure(TestException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void take() {
Observable.range(1, 5)
.mergeWith(Single.just(100))
.take(3)
.test()
.assertResult(1, 2, 3);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void otherError() {
Observable.never()
.mergeWith(Single.error(new TestException()))
.test()
.assertFailure(TestException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void take() {
Observable.range(1, 5)
.mergeWith(Maybe.just(100))
.take(3)
.test()
.assertResult(1, 2, 3);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void mainError() {
Observable.error(new TestException())
.mergeWith(Maybe.just(100))
.test()
.assertFailure(TestException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void otherError() {
Observable.never()
.mergeWith(Maybe.error(new TestException()))
.test()
.assertFailure(TestException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void otherError() {
Observable.never()
.mergeWith(Completable.error(new TestException()))
.test()
.assertFailure(TestException.class);
}
内容来源于网络,如有侵权,请联系作者删除!