@Test public void appendAfterItems() { TestSubscriber<Integer> ts = new TestSubscriber<>(Long.MAX_VALUE); Multi.concat(Multi.range(1, 3), Multi.<Integer>empty()) .onCompleteResumeWith(Multi.range(4, 2)) .subscribe(ts); ts.assertResult(1, 2, 3, 4, 5); }
@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);  }