Update cpp/src/streaming/core/fanout.cpp

nirandaperera · wence- · web-flow · commit 0ad1b4480a02 · 2025-11-20T08:47:13.000-08:00
Co-authored-by: Lawrence Mitchell &lt;wence@gmx.li&gt;
diff --git a/cpp/src/streaming/core/fanout.cpp b/cpp/src/streaming/core/fanout.cpp
@@ -90,6 +90,10 @@ Node bounded_fanout(
             break;
         }
 
+        std::erase_if(chs_out, [](auto&& ch) { return ch->is_shutdown(); });
+        if (chs_out.empty()) {
+            break;
+        }
         co_await send_to_channels(ctx.get(), std::move(msg), chs_out);
         logger.trace("Sent message ", msg.sequence_number());
     }

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,10 @@ Node bounded_fanout(`
`90`	`90`	`break;`
`91`	`91`	`}`
`92`	`92`
	`93`	`+ std::erase_if(chs_out, [](auto&& ch) { return ch->is_shutdown(); });`
	`94`	`+ if (chs_out.empty()) {`
	`95`	`+ break;`
	`96`	`+ }`
`93`	`97`	`co_await send_to_channels(ctx.get(), std::move(msg), chs_out);`
`94`	`98`	`logger.trace("Sent message ", msg.sequence_number());`
`95`	`99`	`}`