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));
	}
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}
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 = >