@Test public void nullFallbackPublisher() { TestSubscriber<Integer> ts = new TestSubscriber<>(); assertThrows(NullPointerException.class, () -> Multi.<Integer>empty() .onCompleteResumeWith(null) .subscribe(ts)); }
@Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnCompleteResumeWithSubscriber<>(subscriber, fallbackPublisher)); }
MultiOnCompleteResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnCompleteResumeWithSubscriber<>(subscriber, fallbackPublisher)); } }
MultiOnCompleteResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnCompleteResumeWithSubscriber<>(subscriber, fallbackPublisher)); } MultiOnCompleteResumeWith(Multi<T> source, Flow.Publisher<? extends T> fallbackPublisher); }
MultiOnCompleteResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnCompleteResumeWithSubscriber<>(subscriber, fallbackPublisher)); } MultiOnCompleteResumeWith(Multi<T> source, Flow.Publisher<? extends T> fallbackPublisher); @Override void subscribe(Flow.Subscriber<? super T> subscriber); }
MultiOnCompleteResumeWith implements Multi<T> { @Override public void subscribe(Flow.Subscriber<? super T> subscriber) { source.subscribe(new OnCompleteResumeWithSubscriber<>(subscriber, fallbackPublisher)); } MultiOnCompleteResumeWith(Multi<T> source, Flow.Publisher<? extends T> fallbackPublisher); @Override void subscribe(Flow.Subscriber<? super T> subscriber);  }