1 files changed, 48 insertions, 0 deletions
diff --git a/rtic/examples/async-channel-try.rs b/rtic/examples/async-channel-try.rs
new file mode 100644
index 0000000..4a79935
--- /dev/null
+++ b/rtic/examples/async-channel-try.rs
@@ -0,0 +1,48 @@
+//! examples/async-channel-try.rs
+
+#![deny(unsafe_code)]
+#![deny(warnings)]
+#![no_main]
+#![no_std]
+#![feature(type_alias_impl_trait)]
+
+use panic_semihosting as _;
+
+#[rtic::app(device = lm3s6965, dispatchers = [SSI0])]
+mod app {
+    use cortex_m_semihosting::{debug, hprintln};
+    use rtic_channel::*;
+
+    #[shared]
+    struct Shared {}
+
+    #[local]
+    struct Local {}
+
+    const CAPACITY: usize = 1;
+    #[init]
+    fn init(_: init::Context) -> (Shared, Local) {
+        let (s, r) = make_channel!(u32, CAPACITY);
+
+        receiver::spawn(r).unwrap();
+        sender1::spawn(s.clone()).unwrap();
+
+        (Shared {}, Local {})
+    }
+
+    #[task]
+    async fn receiver(_c: receiver::Context, mut receiver: Receiver<'static, u32, CAPACITY>) {
+        while let Ok(val) = receiver.recv().await {
+            hprintln!("Receiver got: {}", val);
+        }
+    }
+
+    #[task]
+    async fn sender1(_c: sender1::Context, mut sender: Sender<'static, u32, CAPACITY>) {
+        hprintln!("Sender 1 sending: 1");
+        sender.send(1).await.unwrap();
+        hprintln!("Sender 1 try sending: 2 {:?}", sender.try_send(2));
+        debug::exit(debug::EXIT_SUCCESS); // Exit QEMU simulator
+    }
+
+}