diff options
Diffstat (limited to 'tokio/src/sync/barrier.rs')
| -rw-r--r-- | tokio/src/sync/barrier.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tokio/src/sync/barrier.rs b/tokio/src/sync/barrier.rs index 62863349..23713251 100644 --- a/tokio/src/sync/barrier.rs +++ b/tokio/src/sync/barrier.rs @@ -96,7 +96,7 @@ impl Barrier { // wake everyone, increment the generation, and return state .waker - .broadcast(state.generation) + .send(state.generation) .expect("there is at least one receiver"); state.arrived = 0; state.generation += 1; @@ -112,7 +112,7 @@ impl Barrier { loop { // note that the first time through the loop, this _will_ yield a generation // immediately, since we cloned a receiver that has never seen any values. - if wait.recv().await.expect("sender hasn't been closed") >= generation { + if wait.recv().await >= generation { break; } } |