typo, and also make sure the joinset is not empty

jeromegn · jeromegn · commit a13501abc4af · 2024-12-03T16:29:22.000-05:00
diff --git a/crates/corro-agent/src/broadcast/mod.rs b/crates/corro-agent/src/broadcast/mod.rs
@@ -455,7 +455,7 @@ async fn handle_broadcasts(
                     break;
                 }
             },
-            _ = join_set.next() => {
+            _ = join_set.join_next(), if !join_set.is_empty() => {
                 // drains the joinset
                 continue;
             },

Original file line number	Diff line number	Diff line change
`@@ -455,7 +455,7 @@ async fn handle_broadcasts(`
`455`	`455`	`break;`
`456`	`456`	`}`
`457`	`457`	`},`
`458`		`- _ = join_set.next() => {`
	`458`	`+ _ = join_set.join_next(), if !join_set.is_empty() => {`
`459`	`459`	`// drains the joinset`
`460`	`460`	`continue;`
`461`	`461`	`},`