本文整理了Java中io.reactivex.Observable.empty()
方法的一些代码示例,展示了Observable.empty()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Observable.empty()
方法的具体详情如下:
包路径:io.reactivex.Observable
类名称:Observable
方法名:empty
[英]Returns an Observable that emits no items to the Observer and immediately invokes its Observer#onComplete method.
Scheduler: empty does not operate by default on a particular Scheduler.
[中]返回一个不向观察者发送任何项的可观察对象,并立即调用其观察者#onComplete方法。
Scheduler:默认情况下,empty不会在特定计划程序上运行。
代码示例来源:origin: ReactiveX/RxJava
@Override
public Observable<String> call() {
return Observable.empty();
}
};
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipEmpty() {
Observable<Integer> src = Observable.empty();
src.skipWhile(LESS_THAN_FIVE).subscribe(w);
verify(w, never()).onNext(anyInt());
verify(w, never()).onError(any(Throwable.class));
verify(w, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testFirstOrElseOfNone() {
Observable<String> src = Observable.empty();
src.first("default").subscribe(wo);
verify(wo, times(1)).onSuccess(anyString());
verify(wo, times(1)).onSuccess("default");
verify(wo, never()).onError(any(Throwable.class));
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testTakeLastEmpty() {
Observable<String> w = Observable.empty();
Observable<String> take = w.takeLast(2);
Observer<String> observer = TestHelper.mockObserver();
take.subscribe(observer);
verify(observer, never()).onNext(any(String.class));
verify(observer, never()).onError(any(Throwable.class));
verify(observer, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipEmptyStream() {
Observable<String> w = Observable.empty();
Observable<String> skip = w.skip(1);
Observer<String> observer = TestHelper.mockObserver();
skip.subscribe(observer);
verify(observer, never()).onNext(any(String.class));
verify(observer, never()).onError(any(Throwable.class));
verify(observer, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testFirstWithEmpty() {
Maybe<Integer> o = Observable.<Integer> empty().firstElement();
o.subscribe(wm);
InOrder inOrder = inOrder(wm);
inOrder.verify(wm, times(1)).onComplete();
inOrder.verify(wm, never()).onError(any(Throwable.class));
inOrder.verifyNoMoreInteractions();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testLastWithEmpty() {
Maybe<Integer> o = Observable.<Integer> empty().lastElement();
MaybeObserver<Integer> observer = TestHelper.mockMaybeObserver();
o.subscribe(observer);
InOrder inOrder = inOrder(observer);
inOrder.verify(observer).onComplete();
inOrder.verify(observer, never()).onError(any(Throwable.class));
inOrder.verifyNoMoreInteractions();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void empty() {
ConnectableObservable<Integer> co = Observable.<Integer>empty().publish();
co.connect();
}
代码示例来源:origin: ReactiveX/RxJava
@SuppressWarnings("unchecked")
@Test
public void bufferTimedExactEmpty() {
Observable.empty()
.buffer(1, TimeUnit.DAYS)
.test()
.assertResult(Collections.emptyList());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void timedEmptyOther() {
Observable.empty()
.timeout(1, TimeUnit.DAYS, Observable.just(1))
.test()
.assertResult();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void assertValuePredicateEmpty() {
TestObserver<Object> to = new TestObserver<Object>();
Observable.empty().subscribe(to);
thrown.expect(AssertionError.class);
thrown.expectMessage("No values");
to.assertValue(new Predicate<Object>() {
@Override public boolean test(final Object o) throws Exception {
return false;
}
});
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void empty() {
Observable.<Integer>empty()
.doAfterNext(afterNext)
.subscribeWith(to)
.assertResult();
assertTrue(values.isEmpty());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void elementAtIndex0WithDefaultOnEmptySource() {
Observable.empty()
.elementAt(0, 5)
.test()
.assertResult(5);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void elementAtOrErrorIndex1OnEmptySource() {
Observable.empty()
.elementAtOrError(1)
.test()
.assertFailure(NoSuchElementException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@SuppressWarnings("unchecked")
@Test
public void combineLatestDelayErrorEmpty() {
assertSame(Observable.empty(), Observable.combineLatestDelayError(new ObservableSource[0], Functions.<Object[]>identity(), 16));
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testLastWithNoElements() {
Maybe<?> last = Observable.empty().lastElement();
assertNull(last.blockingGet());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testLastOfEmptyReturnsEmpty() {
TestObserver<Object> to = new TestObserver<Object>();
Observable.empty().takeLast(1).subscribe(to);
to.assertNoValues();
to.assertNoErrors();
to.assertTerminated();
// NO longer assertable
// s.assertUnsubscribed();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void elementAtOrErrorNoElement() {
Observable.empty()
.elementAtOrError(0)
.test()
.assertNoValues()
.assertError(NoSuchElementException.class);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void elementAtIndex1WithDefaultOnEmptySourceObservable() {
Observable.empty()
.elementAt(1, 10)
.toObservable()
.test()
.assertResult(10);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void scalarEmptySource() {
CompletableSubject cs = CompletableSubject.create();
Observable.empty()
.switchMapCompletable(Functions.justFunction(cs))
.test()
.assertResult();
assertFalse(cs.hasObservers());
}
内容来源于网络,如有侵权,请联系作者删除!