Merge pull request #30235 from toshetah/patch-1

Fix Broadcast examples, as they currently fail.
akka · May 12, 2021 · 245527c · 245527c
2 parents f568d4d + 82fc6c0
commit 245527c
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/akka-docs/src/test/scala/docs/stream/operators/BroadcastDocExample.scala b/akka-docs/src/test/scala/docs/stream/operators/BroadcastDocExample.scala
@@ -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