reactor-core/src/main/java/reactor/core/publisher/Flux.java
public static <T> Flux<T> fromStream(Supplier<Stream<? extends T>> streamSupplier) {
		return onAssembly(new FluxStream<>(streamSupplier));
	}
public static <T> Flux<T> fromStream(Supplier<Stream<? extends T>> streamSupplier) {
		return onAssembly(new FluxStream<>(streamSupplier));
	}
Create a {@link Flux} that emits the items contained in a {@link Stream} created by
the provided {@link Supplier} for each subscription. The {@link Stream} is
{@link Stream#close() closed} automatically by the operator on cancellation, error
or completion.
<p>
<img class="marble" src="doc-files/marbles/fromStream.svg" alt="">

@param streamSupplier the {@link Supplier} that generates the {@link Stream} from
which to read data
@param <T> The type of values in the source {@link Stream} and resulting Flux

@return a new {@link Flux}