commit e4367cbca0bbb42cedafa6c42c959bf368528894
author Adam Snaider <adam.snaider@bluerivertech.com> Fri Oct 20 15:14:31 2023 -0400
committer James Kuszmaul <jabukuszmaul+collab@gmail.com> Mon Feb 19 13:49:36 2024 -0800
tree 7513894c931645df726a7674b8984614b9cc242e
parent e98c24875fb5ce62a57cb4d7eb92a019da9f5d94

Pass the EventLoopRuntime by value

Now that the EventLoopRuntime simply wraps a &CppEventLoopRuntime,
we can make give the spawned task an owned EventLoopRuntime. This means
that the spawned future can now own and use the EventLoopRuntime within it.
This is safe because as long as the EventLoop exists, so does the
CppEventLoopRuntime.

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

aos/events/ping.rs

diff --git a/aos/events/ping.rs b/aos/events/ping.rs
index e85ae06..d9673fa 100644
--- a/aos/events/ping.rs
+++ b/aos/events/ping.rs
@@ -28,7 +28,7 @@
     let ping = PingTask::new();
     ShmEventLoop::new(&config).run_with(|runtime| {
         runtime.set_realtime_priority(5);
-        runtime.spawn(ping.tasks(runtime, app.sleep));
+        runtime.spawn(ping.tasks(*runtime, app.sleep));
     });
 }
 
@@ -45,8 +45,8 @@
     }
 
     /// Returns a future with all the tasks for the ping process
-    pub async fn tasks(&self, event_loop: &EventLoopRuntime<'_>, sleep: u64) -> Never {
-        futures::join!(self.ping(event_loop, sleep), self.handle_pong(event_loop));
+    pub async fn tasks(&self, event_loop: EventLoopRuntime<'_>, sleep: u64) -> Never {
+        futures::join!(self.ping(&event_loop, sleep), self.handle_pong(&event_loop));
         unreachable!("Let's hope `never_type` gets stabilized soon :)");
     }