map

Transform each element in the stream by calling a mapping function with it and passing the returned value downstream.

Simple operators

Signature

Source.mapSource.map Flow.mapFlow.map

Description

Transform each element in the stream by calling a mapping function with it and passing the returned value downstream.

Examples

Scala

copysourceimport akka.NotUsed
import akka.stream.scaladsl._

val source: Source[Int, NotUsed] = Source(1 to 10)
val mapped: Source[String, NotUsed] = source.map(elem => elem.toString)

Reactive Streams semantics