Fix comment in hashtag example of streams quickstart doc

This commit is contained in:
Pierre-Marie Padiou 2019-01-17 16:51:28 +01:00 committed by Patrik Nordwall
parent b4fa591d64
commit dcb17b1d0c

View file

@ -156,7 +156,7 @@ class TwitterStreamQuickstartDocSpec extends AkkaSpec {
.filterNot(_.hashtags.contains(akkaTag)) // Remove all tweets containing #akka hashtag
.map(_.hashtags) // Get all sets of hashtags ...
.reduce(_ ++ _) // ... and reduce them to a single set, removing duplicates across all tweets
.mapConcat(identity) // Flatten the stream of tweets to a stream of hashtags
.mapConcat(identity) // Flatten the set of hashtags to a stream of hashtags
.map(_.name.toUpperCase) // Convert all hashtags to upper case
.runWith(Sink.foreach(println)) // Attach the Flow to a Sink that will finally print the hashtags