@Test public void emptySource() { TestSubscriber<Integer> ts = new TestSubscriber<>(); Single.<Integer>empty() .onErrorResume(Object::hashCode) .subscribe(ts); ts.assertResult(); }
@Override public void subscribe(Flow.Subscriber<? super T> subscriber) { Objects.requireNonNull(subscriber, "subscriber is null"); source.subscribe(new OnErrorResumeSubscriber<>(subscriber, fallbackFunction)); }
SingleOnErrorResume extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { Objects.requireNonNull(subscriber, "subscriber is null"); source.subscribe(new OnErrorResumeSubscriber<>(subscriber, fallbackFunction)); } }
SingleOnErrorResume extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { Objects.requireNonNull(subscriber, "subscriber is null"); source.subscribe(new OnErrorResumeSubscriber<>(subscriber, fallbackFunction)); } SingleOnErrorResume(Single<T> source,
                        Function<? super Throwable, ? extends T> fallbackFunction); }
SingleOnErrorResume extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { Objects.requireNonNull(subscriber, "subscriber is null"); source.subscribe(new OnErrorResumeSubscriber<>(subscriber, fallbackFunction)); } SingleOnErrorResume(Single<T> source,
                        Function<? super Throwable, ? extends T> fallbackFunction); @Override void subscribe(Flow.Subscriber<? super T> subscriber); }
SingleOnErrorResume extends CompletionSingle<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { Objects.requireNonNull(subscriber, "subscriber is null"); source.subscribe(new OnErrorResumeSubscriber<>(subscriber, fallbackFunction)); } SingleOnErrorResume(Single<T> source,
                        Function<? super Throwable, ? extends T> fallbackFunction); @Override void subscribe(Flow.Subscriber<? super T> subscriber);  }