@Test public void emptyFallback() { TestSubscriber<Integer> ts = new TestSubscriber<>(); Multi.<Integer>error(new IOException()) .onErrorResumeWith(e -> Multi.empty()) .subscribe(ts); ts.assertResult(); }
@Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnErrorResumeWithSubscriber<>(subscriber, fallbackFunction)); }
MultiOnErrorResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnErrorResumeWithSubscriber<>(subscriber, fallbackFunction)); } }
MultiOnErrorResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnErrorResumeWithSubscriber<>(subscriber, fallbackFunction)); } MultiOnErrorResumeWith(Multi<T> source,
           Function<? super Throwable, ? extends Flow.Publisher<? extends T>> fallbackFunction); }
MultiOnErrorResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnErrorResumeWithSubscriber<>(subscriber, fallbackFunction)); } MultiOnErrorResumeWith(Multi<T> source,
           Function<? super Throwable, ? extends Flow.Publisher<? extends T>> fallbackFunction); @Override void subscribe(Flow.Subscriber<? super T> subscriber); }
MultiOnErrorResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnErrorResumeWithSubscriber<>(subscriber, fallbackFunction)); } MultiOnErrorResumeWith(Multi<T> source,
           Function<? super Throwable, ? extends Flow.Publisher<? extends T>> fallbackFunction); @Override void subscribe(Flow.Subscriber<? super T> subscriber);  }