aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rw-r--r--examples/nrf/src/bin/mpsc.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/examples/nrf/src/bin/mpsc.rs b/examples/nrf/src/bin/mpsc.rs
index eafa29e60..6a0f8f471 100644
--- a/examples/nrf/src/bin/mpsc.rs
+++ b/examples/nrf/src/bin/mpsc.rs
@@ -11,7 +11,7 @@ mod example_common;
11use defmt::panic; 11use defmt::panic;
12use embassy::executor::Spawner; 12use embassy::executor::Spawner;
13use embassy::time::{Duration, Timer}; 13use embassy::time::{Duration, Timer};
14use embassy::util::mpsc::{ChannelCell, TryRecvError}; 14use embassy::util::mpsc::TryRecvError;
15use embassy::util::{mpsc, Forever}; 15use embassy::util::{mpsc, Forever};
16use embassy_nrf::gpio::{Level, Output, OutputDrive}; 16use embassy_nrf::gpio::{Level, Output, OutputDrive};
17use embassy_nrf::Peripherals; 17use embassy_nrf::Peripherals;
@@ -23,10 +23,10 @@ enum LedState {
23 Off, 23 Off,
24} 24}
25 25
26static CHANNEL: Forever<ChannelCell<Channel<WithThreadModeOnly, LedState, 1>>> = Forever::new(); 26static CHANNEL: Forever<Channel<WithThreadModeOnly, LedState, 1>> = Forever::new();
27 27
28#[embassy::task(pool_size = 1)] 28#[embassy::task(pool_size = 1)]
29async fn my_task(sender: Sender<'static, LedState>) { 29async fn my_task(sender: Sender<'static, WithThreadModeOnly, LedState, 1>) {
30 loop { 30 loop {
31 let _ = sender.send(LedState::On).await; 31 let _ = sender.send(LedState::On).await;
32 Timer::after(Duration::from_secs(1)).await; 32 Timer::after(Duration::from_secs(1)).await;
@@ -39,7 +39,7 @@ async fn my_task(sender: Sender<'static, LedState>) {
39async fn main(spawner: Spawner, p: Peripherals) { 39async fn main(spawner: Spawner, p: Peripherals) {
40 let mut led = Output::new(p.P0_13, Level::Low, OutputDrive::Standard); 40 let mut led = Output::new(p.P0_13, Level::Low, OutputDrive::Standard);
41 41
42 let channel = CHANNEL.put(ChannelCell::new(Channel::with_thread_mode_only())); 42 let channel = CHANNEL.put(Channel::with_thread_mode_only());
43 let (sender, mut receiver) = mpsc::split(channel); 43 let (sender, mut receiver) = mpsc::split(channel);
44 44
45 spawner.spawn(my_task(sender)).unwrap(); 45 spawner.spawn(my_task(sender)).unwrap();