Fix Broadcast examples, as they currently fail.

Use different outputs for broadcast
akka · May 11, 2021 · 82fc6c0 · 82fc6c0
1 parent f568d4d
commit 82fc6c0
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