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/channel.rs | |
| parent | 51d87c6603631fda6fb59ca1a65a99c08138b081 (diff) | |
embassy-sync: fix clear() to wake senders
Diffstat (limited to 'embassy-sync/src/channel.rs')
| -rw-r--r-- | embassy-sync/src/channel.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/embassy-sync/src/channel.rs b/embassy-sync/src/channel.rs index 18b053111..9a7d2fa2f 100644 --- a/embassy-sync/src/channel.rs +++ b/embassy-sync/src/channel.rs | |||
| @@ -562,6 +562,9 @@ impl<T, const N: usize> ChannelState<T, N> { | |||
| 562 | } | 562 | } |
| 563 | 563 | ||
| 564 | fn clear(&mut self) { | 564 | fn clear(&mut self) { |
| 565 | if self.queue.is_full() { | ||
| 566 | self.senders_waker.wake(); | ||
| 567 | } | ||
| 565 | self.queue.clear(); | 568 | self.queue.clear(); |
| 566 | } | 569 | } |
| 567 | 570 | ||