class 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);

}