diff options
| author | Ruben De Smet <[email protected]> | 2023-08-11 11:15:17 +0200 |
|---|---|---|
| committer | Ruben De Smet <[email protected]> | 2023-08-11 12:13:46 +0200 |
| commit | f9d251cd5cd9c84718cd66e7697a8502c4d61a0a (patch) | |
| tree | a5609c9b9ea462da66ffed7d82b6409fec1ad2f3 /embassy-stm32/src | |
| parent | b658f10db9a963d85b8465759692b0aa7973a1d1 (diff) | |
Channel poll methods return Poll instead of bool
Diffstat (limited to 'embassy-stm32/src')
| -rw-r--r-- | embassy-stm32/src/can/bxcan.rs | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/embassy-stm32/src/can/bxcan.rs b/embassy-stm32/src/can/bxcan.rs index fb223e4a9..e439207ef 100644 --- a/embassy-stm32/src/can/bxcan.rs +++ b/embassy-stm32/src/can/bxcan.rs | |||
| @@ -506,14 +506,7 @@ impl<'c, 'd, T: Instance> CanRx<'c, 'd, T> { | |||
| 506 | 506 | ||
| 507 | /// Waits while receive queue is empty. | 507 | /// Waits while receive queue is empty. |
| 508 | pub async fn wait_not_empty(&mut self) { | 508 | pub async fn wait_not_empty(&mut self) { |
| 509 | poll_fn(|cx| { | 509 | poll_fn(|cx| T::state().rx_queue.poll_ready_to_receive(cx)).await |
| 510 | if T::state().rx_queue.poll_ready_to_receive(cx) { | ||
| 511 | Poll::Ready(()) | ||
| 512 | } else { | ||
| 513 | Poll::Pending | ||
| 514 | } | ||
| 515 | }) | ||
| 516 | .await | ||
| 517 | } | 510 | } |
| 518 | 511 | ||
| 519 | fn curr_error(&self) -> Option<BusError> { | 512 | fn curr_error(&self) -> Option<BusError> { |