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

Merge pull request #30235 from toshetah/patch-1

Browse source 
Fix Broadcast examples, as they currently fail.
This commit is contained in:
Patrik Nordwall 2021-05-12 13:09:14 +02:00 • committed by GitHub
commit 245527cacb
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))
source ~> broadcast
broadcast.out(0) ~> countS
broadcast.out(0) ~> minS
broadcast.out(0) ~> maxS
broadcast.out(1) ~> minS
broadcast.out(2) ~> maxS
ClosedShape
})
.run()
@ -54,8 +54,8 @@ object BroadcastDocExample {
val broadcast = builder.add(Broadcast[Int](3))
source ~> broadcast
broadcast.out(0) ~> Flow[Int].async ~> countS
broadcast.out(0) ~> Flow[Int].async ~> minS
broadcast.out(0) ~> Flow[Int].async ~> maxS
broadcast.out(1) ~> Flow[Int].async ~> minS
broadcast.out(2) ~> Flow[Int].async ~> maxS
ClosedShape
})
//#broadcast-async