diff options
| author | ibuki2003 <[email protected]> | 2025-01-26 17:23:41 +0900 |
|---|---|---|
| committer | ibuki2003 <[email protected]> | 2025-01-26 17:23:41 +0900 |
| commit | e2ddba92f7f3f9e64da10e8351e335989f388109 (patch) | |
| tree | c6d7e38197da8576b5718611bdeb8eb0c03d52fb /embassy-sync/src/priority_channel.rs | |
| parent | 51d87c6603631fda6fb59ca1a65a99c08138b081 (diff) | |
embassy-sync: fix clear() to wake senders
Diffstat (limited to 'embassy-sync/src/priority_channel.rs')
| -rw-r--r-- | embassy-sync/src/priority_channel.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/embassy-sync/src/priority_channel.rs b/embassy-sync/src/priority_channel.rs index d466a22ff..36959204f 100644 --- a/embassy-sync/src/priority_channel.rs +++ b/embassy-sync/src/priority_channel.rs | |||
| @@ -411,6 +411,9 @@ where | |||
| 411 | } | 411 | } |
| 412 | 412 | ||
| 413 | fn clear(&mut self) { | 413 | fn clear(&mut self) { |
| 414 | if self.queue.len() == self.queue.capacity() { | ||
| 415 | self.senders_waker.wake(); | ||
| 416 | } | ||
| 414 | self.queue.clear(); | 417 | self.queue.clear(); |
| 415 | } | 418 | } |
| 416 | 419 | ||