reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final <V> Flux<V> map(Function<? super T, ? extends V> mapper) {
		if (this instanceof Fuseable) {
			return onAssembly(new FluxMapFuseable<>(this, mapper));
		}
		return onAssembly(new FluxMap<>(this, mapper));
	}
public final <V> Flux<V> map(Function<? super T, ? extends V> mapper) {
		if (this instanceof Fuseable) {
			return onAssembly(new FluxMapFuseable<>(this, mapper));
		}
		return onAssembly(new FluxMap<>(this, mapper));
	}
Transform the items emitted by this {@link Flux} by applying a synchronous function
to each item.
<p>
<img class="marble" src="doc-files/marbles/mapForFlux.svg" alt="">

@param mapper the synchronous transforming {@link Function}
@param <V> the transformed type

@reactor.errorMode This operator supports {@link #onErrorContinue(BiConsumer) resuming on errors}
(including when fusion is enabled). Exceptions thrown by the mapper then cause the
source value to be dropped and a new element ({@code request(1)}) being requested
from upstream.

@return a transformed {@link Flux}