code: public static <T> Flux<T> fromStream(Supplier<Stream<? extends T>> streamSupplier) {
  		return onAssembly(new FluxStream<>(streamSupplier));
  	}
docs: 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}