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

Fix Broadcast examples, as they currently fail.

Browse source 
Use different outputs for broadcast
This commit is contained in:
Tomer Shetah 2021-05-11 15:29:28 +03:00 • committed by GitHub
parent f568d4d4f9
commit 82fc6c0e68
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-docs/src/test/scala/docs/stream/operators/BroadcastDocExample.scala
View file

@ -40,8 +40,8 @@ object BroadcastDocExample {
val broadcast = builder.add(Broadcast[Int](3)) val broadcast = builder.add(Broadcast[Int](3))
source ~> broadcast source ~> broadcast
broadcast.out(0) ~> countS broadcast.out(0) ~> countS
broadcast.out(0) ~> minS broadcast.out(1) ~> minS
broadcast.out(0) ~> maxS broadcast.out(2) ~> maxS
ClosedShape ClosedShape
}) })
.run() .run()
@ -54,8 +54,8 @@ object BroadcastDocExample {
val broadcast = builder.add(Broadcast[Int](3)) val broadcast = builder.add(Broadcast[Int](3))
source ~> broadcast source ~> broadcast
broadcast.out(0) ~> Flow[Int].async ~> countS broadcast.out(0) ~> Flow[Int].async ~> countS
broadcast.out(0) ~> Flow[Int].async ~> minS broadcast.out(1) ~> Flow[Int].async ~> minS
broadcast.out(0) ~> Flow[Int].async ~> maxS broadcast.out(2) ~> Flow[Int].async ~> maxS
ClosedShape ClosedShape
}) })
//#broadcast-async //#broadcast-async