reactor-core/src/main/java/reactor/core/publisher/Flux.java
public static <T> Flux<T> fromStream(Stream<? extends T> s) {
		Objects.requireNonNull(s, "Stream s must be provided");
		return onAssembly(new FluxStream<>(() -> s));
	}
public static <T> Flux<T> fromStream(Stream<? extends T> s) {
		Objects.requireNonNull(s, "Stream s must be provided");
		return onAssembly(new FluxStream<>(() -> s));
	}
Create a {@link Flux} that emits the items contained in the provided {@link Stream}.
Keep in mind that a {@link Stream} cannot be re-used, which can be problematic in
case of multiple subscriptions or re-subscription (like with {@link #repeat()} or
{@link #retry()}). 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 s the {@link Stream} to read data from
@param <T> The type of values in the source {@link Stream} and resulting Flux

@return a new {@link Flux}