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

}