code: public static <T> Flux<T> fromStream(Stream<? extends T> s) {
  		Objects.requireNonNull(s, "Stream s must be provided");
  		return onAssembly(new FluxStream<>(() -> s));
  	}
docs: 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}