From 82fc6c0e685ed59551e9ab73f0ca3ffa4de7ff91 Mon Sep 17 00:00:00 2001
From: Tomer Shetah <32904797+toshetah@users.noreply.github.com>
Date: Tue, 11 May 2021 15:29:28 +0300
Subject: [PATCH] Fix Broadcast examples, as they currently fail.

Use different outputs for broadcast
---
 .../scala/docs/stream/operators/BroadcastDocExample.scala | 8 ++++----
 1 file changed, 4 insertions(+), 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
index f3896237af..0a6f17416e 100644
--- 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