diff options
| author | Dario Nieuwenhuis <[email protected]> | 2022-08-28 22:57:35 +0200 |
|---|---|---|
| committer | Dario Nieuwenhuis <[email protected]> | 2022-08-29 01:00:22 +0200 |
| commit | 598689ef43a5dec1aeb8948dd8b5d0e46a62ef81 (patch) | |
| tree | 452bf56a6874a2386da2f907caf87c7b7c26d02c | |
| parent | 2a0df652f37ac00ba3f568b457eabe4e352bc3c3 (diff) | |
futures: move select* and join* to separate modules.
| -rw-r--r-- | embassy-futures/src/join.rs | 10 | ||||
| -rw-r--r-- | embassy-futures/src/lib.rs | 7 | ||||
| -rw-r--r-- | embassy-futures/src/select.rs | 2 | ||||
| -rw-r--r-- | embassy-usb/src/lib.rs | 2 | ||||
| -rw-r--r-- | examples/nrf/src/bin/usb_hid_keyboard.rs | 2 |
5 files changed, 13 insertions, 10 deletions
diff --git a/embassy-futures/src/join.rs b/embassy-futures/src/join.rs index 39a78ccd3..7600d4b8a 100644 --- a/embassy-futures/src/join.rs +++ b/embassy-futures/src/join.rs | |||
| @@ -1,3 +1,5 @@ | |||
| 1 | //! Wait for multiple futures to complete. | ||
| 2 | |||
| 1 | use core::future::Future; | 3 | use core::future::Future; |
| 2 | use core::pin::Pin; | 4 | use core::pin::Pin; |
| 3 | use core::task::{Context, Poll}; | 5 | use core::task::{Context, Poll}; |
| @@ -131,7 +133,7 @@ generate! { | |||
| 131 | /// | 133 | /// |
| 132 | /// let a = async { 1 }; | 134 | /// let a = async { 1 }; |
| 133 | /// let b = async { 2 }; | 135 | /// let b = async { 2 }; |
| 134 | /// let pair = embassy_futures::join(a, b).await; | 136 | /// let pair = embassy_futures::join::join(a, b).await; |
| 135 | /// | 137 | /// |
| 136 | /// assert_eq!(pair, (1, 2)); | 138 | /// assert_eq!(pair, (1, 2)); |
| 137 | /// # }); | 139 | /// # }); |
| @@ -160,7 +162,7 @@ where | |||
| 160 | /// let a = async { 1 }; | 162 | /// let a = async { 1 }; |
| 161 | /// let b = async { 2 }; | 163 | /// let b = async { 2 }; |
| 162 | /// let c = async { 3 }; | 164 | /// let c = async { 3 }; |
| 163 | /// let res = embassy_futures::join3(a, b, c).await; | 165 | /// let res = embassy_futures::join::join3(a, b, c).await; |
| 164 | /// | 166 | /// |
| 165 | /// assert_eq!(res, (1, 2, 3)); | 167 | /// assert_eq!(res, (1, 2, 3)); |
| 166 | /// # }); | 168 | /// # }); |
| @@ -191,7 +193,7 @@ where | |||
| 191 | /// let b = async { 2 }; | 193 | /// let b = async { 2 }; |
| 192 | /// let c = async { 3 }; | 194 | /// let c = async { 3 }; |
| 193 | /// let d = async { 4 }; | 195 | /// let d = async { 4 }; |
| 194 | /// let res = embassy_futures::join4(a, b, c, d).await; | 196 | /// let res = embassy_futures::join::join4(a, b, c, d).await; |
| 195 | /// | 197 | /// |
| 196 | /// assert_eq!(res, (1, 2, 3, 4)); | 198 | /// assert_eq!(res, (1, 2, 3, 4)); |
| 197 | /// # }); | 199 | /// # }); |
| @@ -229,7 +231,7 @@ where | |||
| 229 | /// let c = async { 3 }; | 231 | /// let c = async { 3 }; |
| 230 | /// let d = async { 4 }; | 232 | /// let d = async { 4 }; |
| 231 | /// let e = async { 5 }; | 233 | /// let e = async { 5 }; |
| 232 | /// let res = embassy_futures::join5(a, b, c, d, e).await; | 234 | /// let res = embassy_futures::join::join5(a, b, c, d, e).await; |
| 233 | /// | 235 | /// |
| 234 | /// assert_eq!(res, (1, 2, 3, 4, 5)); | 236 | /// assert_eq!(res, (1, 2, 3, 4, 5)); |
| 235 | /// # }); | 237 | /// # }); |
diff --git a/embassy-futures/src/lib.rs b/embassy-futures/src/lib.rs index ea135b3ab..8c769bdfc 100644 --- a/embassy-futures/src/lib.rs +++ b/embassy-futures/src/lib.rs | |||
| @@ -6,11 +6,10 @@ | |||
| 6 | pub(crate) mod fmt; | 6 | pub(crate) mod fmt; |
| 7 | 7 | ||
| 8 | mod block_on; | 8 | mod block_on; |
| 9 | mod join; | ||
| 10 | mod select; | ||
| 11 | mod yield_now; | 9 | mod yield_now; |
| 12 | 10 | ||
| 11 | pub mod join; | ||
| 12 | pub mod select; | ||
| 13 | |||
| 13 | pub use block_on::*; | 14 | pub use block_on::*; |
| 14 | pub use join::*; | ||
| 15 | pub use select::*; | ||
| 16 | pub use yield_now::*; | 15 | pub use yield_now::*; |
diff --git a/embassy-futures/src/select.rs b/embassy-futures/src/select.rs index c0dd7ecd3..97a81a86d 100644 --- a/embassy-futures/src/select.rs +++ b/embassy-futures/src/select.rs | |||
| @@ -1,3 +1,5 @@ | |||
| 1 | //! Wait for the first of several futures to complete. | ||
| 2 | |||
| 1 | use core::future::Future; | 3 | use core::future::Future; |
| 2 | use core::pin::Pin; | 4 | use core::pin::Pin; |
| 3 | use core::task::{Context, Poll}; | 5 | use core::task::{Context, Poll}; |
diff --git a/embassy-usb/src/lib.rs b/embassy-usb/src/lib.rs index 5a3f8ba88..b165804ef 100644 --- a/embassy-usb/src/lib.rs +++ b/embassy-usb/src/lib.rs | |||
| @@ -12,7 +12,7 @@ mod descriptor_reader; | |||
| 12 | pub mod driver; | 12 | pub mod driver; |
| 13 | pub mod types; | 13 | pub mod types; |
| 14 | 14 | ||
| 15 | use embassy_futures::{select, Either}; | 15 | use embassy_futures::select::{select, Either}; |
| 16 | use heapless::Vec; | 16 | use heapless::Vec; |
| 17 | 17 | ||
| 18 | pub use self::builder::{Builder, Config}; | 18 | pub use self::builder::{Builder, Config}; |
diff --git a/examples/nrf/src/bin/usb_hid_keyboard.rs b/examples/nrf/src/bin/usb_hid_keyboard.rs index ba2159c72..7fdb0b685 100644 --- a/examples/nrf/src/bin/usb_hid_keyboard.rs +++ b/examples/nrf/src/bin/usb_hid_keyboard.rs | |||
| @@ -8,7 +8,7 @@ use core::sync::atomic::{AtomicBool, Ordering}; | |||
| 8 | 8 | ||
| 9 | use defmt::*; | 9 | use defmt::*; |
| 10 | use embassy_executor::Spawner; | 10 | use embassy_executor::Spawner; |
| 11 | use embassy_futures::{select, Either}; | 11 | use embassy_futures::select::{select, Either}; |
| 12 | use embassy_nrf::gpio::{Input, Pin, Pull}; | 12 | use embassy_nrf::gpio::{Input, Pin, Pull}; |
| 13 | use embassy_nrf::usb::{Driver, PowerUsb}; | 13 | use embassy_nrf::usb::{Driver, PowerUsb}; |
| 14 | use embassy_nrf::{interrupt, pac}; | 14 | use embassy_nrf::{interrupt, pac}; |
