public final <U>ParallelFlux<U> map(Function<? super T,? extends U> mapper){
  Objects.requireNonNull(mapper,"mapper");
  return onAssembly(new ParallelUnorderedMap<>(this,mapper));
}

public final < U > ParallelFlux < U > map ( Function < ? super T , ? extends U > mapper ) { Objects . requireNonNull ( mapper , "mapper" ) ; return onAssembly ( new ParallelUnorderedMap < > ( this , mapper ) ) ; }
maps the source values on each ' rail ' to another value . < p > note that the same mapper function may be called from multiple threads concurrently .
