diff --git a/akka-docs/src/main/paradox/stream/operators/Source-or-Flow/map.md b/akka-docs/src/main/paradox/stream/operators/Source-or-Flow/map.md index 6d5d0fa891..38d7915f8c 100644 --- a/akka-docs/src/main/paradox/stream/operators/Source-or-Flow/map.md +++ b/akka-docs/src/main/paradox/stream/operators/Source-or-Flow/map.md @@ -27,4 +27,11 @@ Transform each element in the stream by calling a mapping function with it and p @@@ +## Examples + + +Scala +: @@snip [Flow.scala]($akka$/akka-docs/src/test/scala/docs/stream/operators/Map.scala) { #imports #map } + + diff --git a/akka-docs/src/test/scala/docs/stream/operators/Map.scala b/akka-docs/src/test/scala/docs/stream/operators/Map.scala new file mode 100644 index 0000000000..37f8e6c180 --- /dev/null +++ b/akka-docs/src/test/scala/docs/stream/operators/Map.scala @@ -0,0 +1,19 @@ +/* + * Copyright (C) 2018 Lightbend Inc. + */ + +package docs.stream.operators + +//#imports +import akka.NotUsed +import akka.stream.scaladsl._ + +//#imports + +object Map { + + //#map + val source: Source[Int, NotUsed] = Source(1 to 10) + val mapped: Source[String, NotUsed] = source.map(elem ⇒ elem.toString) + //#map +}