Sample Code

Mono parallel

Mono<>.subscribeOn(Schedulers.parallel());

Mono.zip

Mono.zip((ary)->{
    return xxx;
},mono1,mono2).block();

Flux.flatMap

Flux<B> Flux.flatMap(Function<A>,Flux<B>);

Flux.fromIterable

Flux<A> Flux.fromIterable(Iterable<A>);

Flux.generate

Flux.generate(() -> true, (continued, sink){
  sink.next(returnValue);
  continued =some condition;
  if (!continued)
				sink.complete();
  return continued;
});