reactor-core/src/main/java/reactor/core/publisher/Flux.java
public static <T> Flux<T> generate(Consumer<SynchronousSink<T>> generator) {
		Objects.requireNonNull(generator, "generator");
		return onAssembly(new FluxGenerate<>(generator));
	}
public static <T> Flux<T> generate(Consumer<SynchronousSink<T>> generator) {
		Objects.requireNonNull(generator, "generator");
		return onAssembly(new FluxGenerate<>(generator));
	}
Programmatically create a {@link Flux} by generating signals one-by-one via a
consumer callback.
<p>
<img class="marble" src="doc-files/marbles/generateStateless.svg" alt="">

@param <T> the value type emitted
@param generator Consume the {@link SynchronousSink} provided per-subscriber by Reactor
to generate a <strong>single</strong> signal on each pass.

@return a {@link Flux}