reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<T> onErrorResume(Predicate<? super Throwable> predicate,
			Function<? super Throwable, ? extends Publisher<? extends T>> fallback) {
		Objects.requireNonNull(predicate, "predicate");
		return onErrorResume(e -> predicate.test(e) ? fallback.apply(e) : error(e));
	}
public final Flux<T> onErrorResume(Predicate<? super Throwable> predicate,
			Function<? super Throwable, ? extends Publisher<? extends T>> fallback) {
		Objects.requireNonNull(predicate, "predicate");
		return onErrorResume(e -> predicate.test(e) ? fallback.apply(e) : error(e));
	}
Subscribe to a fallback publisher when an error matching a given predicate
occurs.
<p>
<img class="marble" src="doc-files/marbles/onErrorResumeForFlux.svg" alt="">

@param predicate the error predicate to match
@param fallback the function to choose the fallback to an alternative {@link Publisher}

@return a {@link Flux} falling back upon source onError