tasks initial impl (still working on task_on trait method)

src/default/mod.rs

@@ -17,6 +17,7 @@ mod event;
 mod input;
 mod render;
 mod sense;
+mod task;
 
 pub use app::*;
 pub use attr::*;
@@ -24,6 +25,7 @@ pub use event::*;
 pub use input::*;
 pub use render::*;
 pub use sense::*;
+pub use task::*;
 
 pub type Proxy<Event> = EventLoopProxy<Event>;
 
@@ -79,19 +81,25 @@ pub trait DefaultAppState: HasDefaultUiState {
     }
 }
 
-pub struct DefaultRsc<State> {
+pub struct DefaultRsc<State: 'static> {
     pub ui: Ui,
     pub events: EventManager<Self>,
+    pub tasks: Tasks<Self>,
     _state: PhantomData<State>,
 }
 
-impl<State> Default for DefaultRsc<State> {
-    fn default() -> Self {
-        Self {
-            ui: Default::default(),
-            events: Default::default(),
-            _state: Default::default(),
-        }
+impl<State> DefaultRsc<State> {
+    fn init(window: Arc<Window>) -> (Self, TaskMsgReceiver<Self>) {
+        let (tasks, recv) = Tasks::init(window);
+        (
+            Self {
+                ui: Default::default(),
+                events: Default::default(),
+                tasks,
+                _state: Default::default(),
+            },
+            recv,
+        )
     }
 }
 
@@ -105,9 +113,11 @@ impl<State> HasUi for DefaultRsc<State> {
     }
 }
 
-impl<State: 'static> HasEvents for DefaultRsc<State> {
+impl<State: 'static> HasState for DefaultRsc<State> {
     type State = State;
+}
 
+impl<State: 'static> HasEvents for DefaultRsc<State> {
     fn events(&self) -> &EventManager<Self> {
         &self.events
     }
@@ -120,11 +130,9 @@ impl<State: 'static> HasEvents for DefaultRsc<State> {
 pub struct DefaultApp<State: DefaultAppState> {
     rsc: DefaultRsc<State>,
     state: State,
+    task_recv: TaskMsgReceiver<DefaultRsc<State>>,
 }
 
-// impl StateLike for DefaultRsc<State> {
-// }
-//
 impl<State: DefaultAppState> AppState for DefaultApp<State> {
     type Event = State::Event;
 
@@ -132,9 +140,14 @@ impl<State: DefaultAppState> AppState for DefaultApp<State> {
         let window = event_loop
             .create_window(State::window_attributes())
             .unwrap();
-        let mut rsc = DefaultRsc::default();
-        let state = State::new(DefaultUiState::new(window), &mut rsc, proxy);
-        Self { rsc, state }
+        let default_state = DefaultUiState::new(window);
+        let (mut rsc, task_recv) = DefaultRsc::init(default_state.window.clone());
+        let state = State::new(default_state, &mut rsc, proxy);
+        Self {
+            rsc,
+            state,
+            task_recv,
+        }
     }
 
     fn event(&mut self, event: Self::Event, _: &ActiveEventLoop) {
@@ -142,6 +155,10 @@ impl<State: DefaultAppState> AppState for DefaultApp<State> {
     }
 
     fn window_event(&mut self, event: WindowEvent, event_loop: &ActiveEventLoop) {
+        for update in self.task_recv.try_iter() {
+            update(&mut self.state, &mut self.rsc);
+        }
+
         let ui_state = self.state.default_state_mut();
         let input_changed = ui_state.input.event(&event);
         let cursor_state = ui_state.cursor_state().clone();

src/default/task.rs

@@ -0,0 +1,85 @@
+use iris_core::HasState;
+use std::{
+    pin::Pin,
+    sync::{
+        Arc,
+        mpsc::{Receiver as SyncReceiver, Sender as SyncSender, channel as sync_channel},
+    },
+};
+use tokio::{
+    runtime::Runtime,
+    sync::mpsc::{
+        UnboundedReceiver as AsyncReceiver, UnboundedSender as AsyncSender,
+        unbounded_channel as async_channel,
+    },
+};
+use winit::window::Window;
+
+pub type TaskMsgSender<Rsc> = SyncSender<Box<dyn TaskUpdate<Rsc>>>;
+pub type TaskMsgReceiver<Rsc> = SyncReceiver<Box<dyn TaskUpdate<Rsc>>>;
+
+pub trait TaskUpdate<Rsc: HasState>: FnOnce(&mut Rsc::State, &mut Rsc) + Send {}
+impl<F: FnOnce(&mut Rsc::State, &mut Rsc) + Send, Rsc: HasState> TaskUpdate<Rsc> for F {}
+
+pub struct Tasks<Rsc: HasState> {
+    start: AsyncSender<BoxTask>,
+    window: Arc<Window>,
+    msg_send: SyncSender<Box<dyn TaskUpdate<Rsc>>>,
+}
+
+pub struct TaskCtx<Rsc: HasState> {
+    send: TaskMsgSender<Rsc>,
+}
+
+impl<Rsc: HasState> TaskCtx<Rsc> {
+    pub fn update(&mut self, f: impl TaskUpdate<Rsc> + 'static) {
+        let _ = self.send.send(Box::new(f));
+    }
+}
+impl<Rsc: HasState + 'static> TaskCtx<Rsc> {
+    fn new(send: TaskMsgSender<Rsc>) -> Self {
+        Self { send }
+    }
+}
+
+type BoxTask = Pin<Box<dyn Future<Output = ()> + Send>>;
+
+impl<Rsc: HasState> Tasks<Rsc> {
+    pub fn init(window: Arc<Window>) -> (Self, TaskMsgReceiver<Rsc>) {
+        let (start, start_recv) = async_channel();
+        let (msgs, msgs_recv) = sync_channel();
+        std::thread::spawn(|| {
+            let rt = Runtime::new().unwrap();
+            rt.block_on(listen(start_recv))
+        });
+        (
+            Self {
+                start,
+                msg_send: msgs,
+                window,
+            },
+            msgs_recv,
+        )
+    }
+
+    pub fn spawn<F: for<'a> AsyncFnOnce(&'a mut TaskCtx<Rsc>) + 'static + std::marker::Send>(
+        &mut self,
+        task: F,
+    ) where
+        for<'a> <F as AsyncFnOnce<(&'a mut TaskCtx<Rsc>,)>>::CallOnceFuture: Send,
+    {
+        let send = self.msg_send.clone();
+        let window = self.window.clone();
+        let _ = self.start.send(Box::pin(async move {
+            let mut ctx = TaskCtx::new(send);
+            task(&mut ctx).await;
+            window.request_redraw();
+        }));
+    }
+}
+
+async fn listen(mut recv: AsyncReceiver<BoxTask>) {
+    while let Some(task) = recv.recv().await {
+        tokio::spawn(task);
+    }
+}