本文整理了Java中io.reactivex.Observable.skip()
方法的一些代码示例,展示了Observable.skip()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Observable.skip()
方法的具体详情如下:
包路径:io.reactivex.Observable
类名称:Observable
方法名:skip
[英]Returns an Observable that skips the first count items emitted by the source ObservableSource and emits the remainder.
Scheduler: This version of skip does not operate by default on a particular Scheduler.
[中]返回一个Observable,它跳过源ObservableSource发出的第一个计数项,并发出剩余的计数项。
调度程序:默认情况下,此版本的skip不会在特定调度程序上运行。
代码示例来源:origin: ReactiveX/RxJava
@Override
public Observable<Object> apply(Observable<Object> o)
throws Exception {
return o.skip(1);
}
});
代码示例来源:origin: ReactiveX/RxJava
@Test(expected = NullPointerException.class)
public void skipTimedSchedulerNull() {
just1.skip(1, TimeUnit.SECONDS, null);
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipNegativeElements() {
Observable<String> skip = Observable.just("one", "two", "three").skip(-99);
Observer<String> observer = TestHelper.mockObserver();
skip.subscribe(observer);
verify(observer, times(1)).onNext("one");
verify(observer, times(1)).onNext("two");
verify(observer, times(1)).onNext("three");
verify(observer, never()).onError(any(Throwable.class));
verify(observer, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipTwoElements() {
Observable<String> skip = Observable.just("one", "two", "three").skip(2);
Observer<String> observer = TestHelper.mockObserver();
skip.subscribe(observer);
verify(observer, never()).onNext("one");
verify(observer, never()).onNext("two");
verify(observer, times(1)).onNext("three");
verify(observer, never()).onError(any(Throwable.class));
verify(observer, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void dispose() {
TestHelper.checkDisposed(Observable.just(1).skip(2));
}
代码示例来源: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 testSkipZeroElements() {
Observable<String> skip = Observable.just("one", "two", "three").skip(0);
Observer<String> observer = TestHelper.mockObserver();
skip.subscribe(observer);
verify(observer, times(1)).onNext("one");
verify(observer, times(1)).onNext("two");
verify(observer, times(1)).onNext("three");
verify(observer, never()).onError(any(Throwable.class));
verify(observer, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipOneElement() {
Observable<String> skip = Observable.just("one", "two", "three").skip(1);
Observer<String> observer = TestHelper.mockObserver();
skip.subscribe(observer);
verify(observer, never()).onNext("one");
verify(observer, times(1)).onNext("two");
verify(observer, times(1)).onNext("three");
verify(observer, never()).onError(any(Throwable.class));
verify(observer, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipError() {
Exception e = new Exception();
Observable<String> ok = Observable.just("one");
Observable<String> error = Observable.error(e);
Observable<String> skip = Observable.concat(ok, error).skip(100);
Observer<String> observer = TestHelper.mockObserver();
skip.subscribe(observer);
verify(observer, never()).onNext(any(String.class));
verify(observer, times(1)).onError(e);
verify(observer, never()).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Test(expected = NullPointerException.class)
public void skipTimedUnitNull() {
just1.skip(1, null, Schedulers.single());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testSkipMultipleObservers() {
Observable<String> skip = Observable.just("one", "two", "three")
.skip(2);
Observer<String> observer1 = TestHelper.mockObserver();
skip.subscribe(observer1);
Observer<String> observer2 = TestHelper.mockObserver();
skip.subscribe(observer2);
verify(observer1, times(1)).onNext(any(String.class));
verify(observer1, never()).onError(any(Throwable.class));
verify(observer1, times(1)).onComplete();
verify(observer2, times(1)).onNext(any(String.class));
verify(observer2, never()).onError(any(Throwable.class));
verify(observer2, times(1)).onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Override
public Observable<Movie> apply(Observable<List<Movie>> movieList) {
return movieList
.startWith(new ArrayList<Movie>())
.buffer(2, 1)
.skip(1)
.flatMap(calculateDelta);
}
};
代码示例来源:origin: ReactiveX/RxJava
@Test
public void skipTimedDefaultScheduler() {
Observable.just(1).skip(1, TimeUnit.MINUTES)
.test()
.awaitDone(5, TimeUnit.SECONDS)
.assertResult();
}
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testRequestOverflowDoesNotOccur() {
TestObserver<Integer> to = new TestObserver<Integer>();
Observable.range(1, 10).skip(5).subscribe(to);
to.assertTerminated();
to.assertComplete();
to.assertNoErrors();
assertEquals(Arrays.asList(6, 7, 8, 9, 10), to.values());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testAsyncComeAndGo() {
Observable<Long> source = Observable.interval(1, 1, TimeUnit.MILLISECONDS)
.take(1000)
.subscribeOn(Schedulers.io());
Observable<Long> cached = source.replay().autoConnect();
Observable<Long> output = cached.observeOn(Schedulers.computation());
List<TestObserver<Long>> list = new ArrayList<TestObserver<Long>>(100);
for (int i = 0; i < 100; i++) {
TestObserver<Long> to = new TestObserver<Long>();
list.add(to);
output.skip(i * 10).take(10).subscribe(to);
}
List<Long> expected = new ArrayList<Long>();
for (int i = 0; i < 10; i++) {
expected.add((long)(i - 10));
}
int j = 0;
for (TestObserver<Long> to : list) {
to.awaitTerminalEvent(3, TimeUnit.SECONDS);
to.assertNoErrors();
to.assertTerminated();
for (int i = j * 10; i < j * 10 + 10; i++) {
expected.set(i - j * 10, (long)i);
}
to.assertValueSequence(expected);
j++;
}
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void testAsyncComeAndGo() {
Observable<Long> source = Observable.interval(1, 1, TimeUnit.MILLISECONDS)
.take(1000)
.subscribeOn(Schedulers.io());
ObservableCache<Long> cached = new ObservableCache<Long>(source, 16);
Observable<Long> output = cached.observeOn(Schedulers.computation());
List<TestObserver<Long>> list = new ArrayList<TestObserver<Long>>(100);
for (int i = 0; i < 100; i++) {
TestObserver<Long> to = new TestObserver<Long>();
list.add(to);
output.skip(i * 10).take(10).subscribe(to);
}
List<Long> expected = new ArrayList<Long>();
for (int i = 0; i < 10; i++) {
expected.add((long)(i - 10));
}
int j = 0;
for (TestObserver<Long> to : list) {
to.awaitTerminalEvent(3, TimeUnit.SECONDS);
to.assertNoErrors();
to.assertComplete();
for (int i = j * 10; i < j * 10 + 10; i++) {
expected.set(i - j * 10, (long)i);
}
to.assertValueSequence(expected);
j++;
}
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void fromIterable() {
ArrayList<String> items = new ArrayList<String>();
items.add("one");
items.add("two");
items.add("three");
assertEquals((Long)3L, Observable.fromIterable(items).count().blockingGet());
assertEquals("two", Observable.fromIterable(items).skip(1).take(1).blockingSingle());
assertEquals("three", Observable.fromIterable(items).takeLast(1).blockingSingle());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void fromArityArgs3() {
Observable<String> items = Observable.just("one", "two", "three");
assertEquals((Long)3L, items.count().blockingGet());
assertEquals("two", items.skip(1).take(1).blockingSingle());
assertEquals("three", items.takeLast(1).blockingSingle());
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void zip2DelayErrorPrefetch() {
Observable.zip(Observable.range(1, 9).concatWith(Observable.<Integer>error(new TestException())),
Observable.range(21, 9),
new BiFunction<Integer, Integer, Object>() {
@Override
public Object apply(Integer a, Integer b) throws Exception {
return "" + a + b;
}
}, true, 2
)
.skip(8)
.test()
.assertFailure(TestException.class, "929");
}
代码示例来源:origin: ReactiveX/RxJava
@Test
public void fromArray() {
String[] items = new String[] { "one", "two", "three" };
assertEquals((Long)3L, Observable.fromArray(items).count().blockingGet());
assertEquals("two", Observable.fromArray(items).skip(1).take(1).blockingSingle());
assertEquals("three", Observable.fromArray(items).takeLast(1).blockingSingle());
}
内容来源于网络,如有侵权,请联系作者删除!