commit a3317c84163b6fe40f4cf42cf21d5c486a403601
author Adam Snaider <adam.snaider@bluerivertech.com> Mon Oct 02 16:02:36 2023 -0700
committer James Kuszmaul <jabukuszmaul+collab@gmail.com> Mon Feb 19 13:48:53 2024 -0800
tree 04fd4a493bc5a68413b9066b94094f2898d374ad
parent 34072e1b96df286d17090e1dc0a83b0fa8aaa67e

Make ping/pong rust example realtime

Change-Id: I9d1a639afe0b87dd9e303a70f9d3ed1989465139
Signed-off-by: James Kuszmaul <james.kuszmaul@bluerivertech.com>

aos/events/shm_event_loop.rs

diff --git a/aos/events/shm_event_loop.rs b/aos/events/shm_event_loop.rs
index cebf81b..04cf42c 100644
--- a/aos/events/shm_event_loop.rs
+++ b/aos/events/shm_event_loop.rs
@@ -65,6 +65,7 @@
     /// # use aos_events_shm_event_loop::*;
     /// use ping_rust_fbs::aos::examples as ping;
     /// use pong_rust_fbs::aos::examples as pong;
+    /// use std::borrow::Borrow;
     /// use std::cell::Cell;
     /// use std::path::Path;
     /// use aos_configuration::read_config_from;
@@ -81,7 +82,7 @@
     ///   let on_run = runtime.on_run();
     ///   // Sends a single ping message.
     ///   let send_task = async move {
-    ///     on_run.await;
+    ///     on_run.borrow().await;
     ///     let mut builder = sender.make_builder();
     ///     let mut ping = ping::PingBuilder::new(builder.fbb());
     ///     ping.add_value(10);
@@ -237,6 +238,7 @@
     use aos_events_event_loop_runtime::{Sender, Watcher};
     use aos_test_init::test_init;
     use ping_rust_fbs::aos::examples as ping;
+    use std::borrow::Borrow;
     use std::sync::atomic::{AtomicUsize, Ordering};
     use std::sync::Barrier;
 
@@ -265,7 +267,7 @@
                         let mut watcher: Watcher<ping::Ping> = runtime
                             .make_watcher("/test")
                             .expect("Can't create `Ping` watcher");
-                        runtime.on_run().await;
+                        runtime.on_run().borrow().await;
                         barrier.wait();
                         let ping = watcher.next().await;
                         assert_eq!(ping.message().unwrap().value(), VALUE);
@@ -282,7 +284,7 @@
                         let mut sender: Sender<ping::Ping> = runtime
                             .make_sender("/test")
                             .expect("Can't create `Ping` sender");
-                        runtime.on_run().await;
+                        runtime.on_run().borrow().await;
                         // Give the waiting thread a chance to start.
                         barrier.wait();
                         let mut sender = sender.make_builder();