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));
	}
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}
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 = >