diff options
author | bors[bot] <26634292+bors[bot]@users.noreply.github.com> | 2022-06-12 06:27:11 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-06-12 06:27:11 +0000 |
commit | 6b3499a5c831e6deb1c8550efdfe7601fa4c6e56 (patch) | |
tree | 21344af53a0823f4949b25dbd2d9011ffe316f8a | |
parent | db344c2bda55bd0352a43720788185cc4d3a420e (diff) | |
parent | 99d19c7dcf077cdd06113bf013d6a458289b1ecb (diff) | |
download | embassy-6b3499a5c831e6deb1c8550efdfe7601fa4c6e56.zip |
Merge #807
807: Rename channel to mpmc r=huntc a=huntc
I've renamed the channel module for the MPMC as `mpmc`. There was a previous debate about this, but I feel that the strategy here avoids importing `channel::channel`. The change leaves `signal::Signal`, but I think that's ok. It is all a bit subjective of course. The bottom line for me is that I really like the term `mpmc` - it means something to me and aligns with broader naming e.g. in Tokio.
Co-authored-by: huntc <huntchr@gmail.com>
-rw-r--r-- | embassy/src/channel/mod.rs | 4 | ||||
-rw-r--r-- | embassy/src/channel/mpmc.rs (renamed from embassy/src/channel/channel.rs) | 4 | ||||
-rw-r--r-- | embassy/src/channel/signal.rs | 2 | ||||
-rw-r--r-- | examples/nrf/src/bin/channel.rs | 2 | ||||
-rw-r--r-- | examples/nrf/src/bin/channel_sender_receiver.rs | 2 | ||||
-rw-r--r-- | examples/nrf/src/bin/uart_split.rs | 2 | ||||
-rw-r--r-- | examples/nrf/src/bin/usb_ethernet.rs | 2 | ||||
-rw-r--r-- | examples/nrf/src/bin/usb_hid_keyboard.rs | 2 | ||||
-rw-r--r-- | examples/stm32f3/src/bin/button_events.rs | 2 | ||||
-rw-r--r-- | examples/stm32h7/src/bin/signal.rs | 2 | ||||
-rw-r--r-- | examples/stm32h7/src/bin/usart_split.rs | 2 | ||||
-rw-r--r-- | examples/stm32l5/src/bin/usb_ethernet.rs | 2 |
12 files changed, 13 insertions, 15 deletions
diff --git a/embassy/src/channel/mod.rs b/embassy/src/channel/mod.rs index 4d37fe85..05edc55d 100644 --- a/embassy/src/channel/mod.rs +++ b/embassy/src/channel/mod.rs @@ -1,7 +1,5 @@ //! Async channels -pub mod channel; -pub use channel::*; +pub mod mpmc; pub mod signal; -pub use signal::*; diff --git a/embassy/src/channel/channel.rs b/embassy/src/channel/mpmc.rs index d74f6365..2377a966 100644 --- a/embassy/src/channel/channel.rs +++ b/embassy/src/channel/mpmc.rs @@ -388,7 +388,7 @@ where /// Establish a new bounded channel. For example, to create one with a NoopMutex: /// /// ``` - /// use embassy::channel::channel::Channel; + /// use embassy::channel::mpmc::Channel; /// use embassy::blocking_mutex::raw::NoopRawMutex; /// /// // Declare a bounded channel of 3 u32s. @@ -404,7 +404,7 @@ where /// Establish a new bounded channel. For example, to create one with a NoopMutex: /// /// ``` - /// use embassy::channel::channel::Channel; + /// use embassy::channel::mpmc::Channel; /// use embassy::blocking_mutex::raw::NoopRawMutex; /// /// // Declare a bounded channel of 3 u32s. diff --git a/embassy/src/channel/signal.rs b/embassy/src/channel/signal.rs index e1f6c4b1..5a2c9d47 100644 --- a/embassy/src/channel/signal.rs +++ b/embassy/src/channel/signal.rs @@ -5,7 +5,7 @@ use core::task::{Context, Poll, Waker}; /// Synchronization primitive. Allows creating awaitable signals that may be passed between tasks. /// For a simple use-case where the receiver is only ever interested in the latest value of -/// something, Signals work well. For more advanced use cases, you might want to use [`Channel`](crate::channel::channel::Channel) instead.. +/// something, Signals work well. For more advanced use cases, you might want to use [`Channel`](crate::channel::mpmc::Channel) instead.. /// /// Signals are generally declared as being a static const and then borrowed as required. /// diff --git a/examples/nrf/src/bin/channel.rs b/examples/nrf/src/bin/channel.rs index 476ec09a..12b46358 100644 --- a/examples/nrf/src/bin/channel.rs +++ b/examples/nrf/src/bin/channel.rs @@ -4,7 +4,7 @@ use defmt::unwrap; use embassy::blocking_mutex::raw::ThreadModeRawMutex; -use embassy::channel::channel::Channel; +use embassy::channel::mpmc::Channel; use embassy::executor::Spawner; use embassy::time::{Duration, Timer}; use embassy_nrf::gpio::{Level, Output, OutputDrive}; diff --git a/examples/nrf/src/bin/channel_sender_receiver.rs b/examples/nrf/src/bin/channel_sender_receiver.rs index c79f2fd6..1742dcc9 100644 --- a/examples/nrf/src/bin/channel_sender_receiver.rs +++ b/examples/nrf/src/bin/channel_sender_receiver.rs @@ -4,7 +4,7 @@ use defmt::unwrap; use embassy::blocking_mutex::raw::NoopRawMutex; -use embassy::channel::channel::{Channel, Receiver, Sender}; +use embassy::channel::mpmc::{Channel, Receiver, Sender}; use embassy::executor::Spawner; use embassy::time::{Duration, Timer}; use embassy::util::Forever; diff --git a/examples/nrf/src/bin/uart_split.rs b/examples/nrf/src/bin/uart_split.rs index 3fde2f0d..958cfeba 100644 --- a/examples/nrf/src/bin/uart_split.rs +++ b/examples/nrf/src/bin/uart_split.rs @@ -4,7 +4,7 @@ use defmt::*; use embassy::blocking_mutex::raw::ThreadModeRawMutex; -use embassy::channel::channel::Channel; +use embassy::channel::mpmc::Channel; use embassy::executor::Spawner; use embassy_nrf::peripherals::UARTE0; use embassy_nrf::uarte::UarteRx; diff --git a/examples/nrf/src/bin/usb_ethernet.rs b/examples/nrf/src/bin/usb_ethernet.rs index 49f2fb89..3d85d22b 100644 --- a/examples/nrf/src/bin/usb_ethernet.rs +++ b/examples/nrf/src/bin/usb_ethernet.rs @@ -8,7 +8,7 @@ use core::sync::atomic::{AtomicBool, Ordering}; use core::task::Waker; use defmt::*; use embassy::blocking_mutex::raw::ThreadModeRawMutex; -use embassy::channel::Channel; +use embassy::channel::mpmc::Channel; use embassy::executor::Spawner; use embassy::util::Forever; use embassy_net::tcp::TcpSocket; diff --git a/examples/nrf/src/bin/usb_hid_keyboard.rs b/examples/nrf/src/bin/usb_hid_keyboard.rs index d855a3a5..d7affae1 100644 --- a/examples/nrf/src/bin/usb_hid_keyboard.rs +++ b/examples/nrf/src/bin/usb_hid_keyboard.rs @@ -6,7 +6,7 @@ use core::mem; use core::sync::atomic::{AtomicBool, Ordering}; use defmt::*; -use embassy::channel::Signal; +use embassy::channel::signal::Signal; use embassy::executor::Spawner; use embassy::interrupt::InterruptExt; use embassy::time::Duration; diff --git a/examples/stm32f3/src/bin/button_events.rs b/examples/stm32f3/src/bin/button_events.rs index 06e8eec1..59370179 100644 --- a/examples/stm32f3/src/bin/button_events.rs +++ b/examples/stm32f3/src/bin/button_events.rs @@ -12,7 +12,7 @@ use defmt::*; use embassy::blocking_mutex::raw::ThreadModeRawMutex; -use embassy::channel::channel::Channel; +use embassy::channel::mpmc::Channel; use embassy::executor::Spawner; use embassy::time::{with_timeout, Duration, Timer}; use embassy_stm32::exti::ExtiInput; diff --git a/examples/stm32h7/src/bin/signal.rs b/examples/stm32h7/src/bin/signal.rs index d2531b2b..c63b2836 100644 --- a/examples/stm32h7/src/bin/signal.rs +++ b/examples/stm32h7/src/bin/signal.rs @@ -8,7 +8,7 @@ use defmt_rtt as _; use panic_probe as _; -use embassy::channel::Signal; +use embassy::channel::signal::Signal; use embassy::executor::Spawner; use embassy::time::{Duration, Timer}; diff --git a/examples/stm32h7/src/bin/usart_split.rs b/examples/stm32h7/src/bin/usart_split.rs index 40a7c3e4..eb3f9578 100644 --- a/examples/stm32h7/src/bin/usart_split.rs +++ b/examples/stm32h7/src/bin/usart_split.rs @@ -5,7 +5,7 @@ use defmt::*; use defmt_rtt as _; // global logger use embassy::blocking_mutex::raw::ThreadModeRawMutex; -use embassy::channel::channel::Channel; +use embassy::channel::mpmc::Channel; use embassy::executor::Spawner; use embassy_stm32::dma::NoDma; use embassy_stm32::{ diff --git a/examples/stm32l5/src/bin/usb_ethernet.rs b/examples/stm32l5/src/bin/usb_ethernet.rs index fa445eec..526b2753 100644 --- a/examples/stm32l5/src/bin/usb_ethernet.rs +++ b/examples/stm32l5/src/bin/usb_ethernet.rs @@ -8,7 +8,7 @@ use core::task::Waker; use defmt::*; use defmt_rtt as _; // global logger use embassy::blocking_mutex::raw::ThreadModeRawMutex; -use embassy::channel::Channel; +use embassy::channel::mpmc::Channel; use embassy::executor::Spawner; use embassy::util::Forever; use embassy_net::tcp::TcpSocket; |