raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=str - #17827 - Introduces operator for Sources and Flows, to attach a Sink in an inline broadcast fashion.

Browse source
This commit is contained in:
Viktor Klang 2015-10-05 23:20:52 +02:00
parent eee21ac618
commit 08d702faf8
8 changed files with 116 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-docs-dev/rst/scala/code/docs/stream/FlowDocSpec.scala
View file

@ -136,6 +136,11 @@ class FlowDocSpec extends AkkaSpec {
val sink: Sink[Int, Unit] = Flow[Int].map(_ * 2).to(Sink.foreach(println(_)))
Source(1 to 6).to(sink)
// Broadcast to a sink inline
val otherSink: Sink[Int, Unit] =
Flow[Int].alsoTo(Sink.foreach(println(_))).to(Sink.ignore)
Source(1 to 6).to(otherSink)
//#flow-connecting
}