contramap

Transform this Flow by applying a function to each incoming upstream element before it is passed to the Flow.

Simple operators

Signature

Flow.contramapFlow.contramap

Description

Transform this Flow by applying a function to each incoming upstream element before it is passed to the Flow.

Examples

Scala

copysourceimport org.apache.pekko.NotUsed
import org.apache.pekko.stream.scaladsl._

val flow: Flow[Int, Int, NotUsed] = Flow[Int]
val newFlow: Flow[String, Int, NotUsed] = flow.contramap(_.toInt)

Reactive Streams semantics