reactor-core/src/main/java/reactor/core/publisher/Flux.java
public static <T> Flux<T> error(Supplier<Throwable> errorSupplier) {
		return onAssembly(new FluxErrorSupplied<>(errorSupplier));
	}
public static <T> Flux<T> error(Supplier<Throwable> errorSupplier) {
		return onAssembly(new FluxErrorSupplied<>(errorSupplier));
	}
public static < T > Flux < T > error ( Supplier < Throwable > errorSupplier ) { return onAssembly ( new FluxErrorSupplied <> ( errorSupplier ) ) ; }
Create a {@link Flux} that terminates with an error immediately after being
subscribed to. The {@link Throwable} is generated by a {@link Supplier}, invoked
each time there is a subscription and allowing for lazy instantiation.
<p>
<img class="marble" src="doc-files/marbles/errorWithSupplier.svg" alt="">

@param errorSupplier the error signal {@link Supplier} to invoke for each {@link Subscriber}
@param <T> the reified type of the target {@link Subscriber}

@return a new failing {@link Flux}
Create a { @link Flux } that terminates with an error immediately after being subscribed to . The { @link Throwable } is generated by a { @link Supplier } invoked each time there is a subscription and allowing for lazy instantiation . <p > <img class = marble src = doc - files / marbles / errorWithSupplier . svg alt = >