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 ) ) ; }
generate signals one - by - one via a consumer callback . < p > < img class = " marble " src = " https : / / raw . githubusercontent . com / reactor / projectreactor . io / master / src / main / static / assets / img / marble / generate . png " alt = " " > < p >
