feat(dispatch-queue): Add dispatch queue and substate support

src/action/enabling_condition.rs

@@ -7,4 +7,3 @@ pub trait EnablingCondition<State> {
         true
     }
 }
-

src/dispatcher.rs

@@ -0,0 +1,37 @@
+use std::{collections::VecDeque, marker::PhantomData};
+
+pub struct Dispatcher<Action, State> {
+    queue: VecDeque<Action>,
+    _marker: PhantomData<State>,
+}
+
+impl<Action, State> Dispatcher<Action, State>
+where
+    Action: crate::EnablingCondition<State>,
+{
+    pub fn new() -> Self {
+        Self {
+            queue: VecDeque::new(),
+            _marker: Default::default(),
+        }
+    }
+
+    pub fn push<T>(&mut self, action: T)
+    where
+        T: Into<Action>,
+    {
+        self.queue.push_back(action.into());
+    }
+
+    pub(crate) fn pop(&mut self) -> Option<Action> {
+        self.queue.pop_front()
+    }
+
+    pub(crate) fn push_front(&mut self, other: Dispatcher<Action, State>) {
+        other
+            .queue
+            .into_iter()
+            .rev()
+            .for_each(|action| self.queue.push_front(action));
+    }
+}

src/lib.rs

@@ -20,3 +20,6 @@ pub use store::{monotonic_to_time, Store};
 
 mod sub_store;
 pub use sub_store::SubStore;
+
+mod dispatcher;
+pub use dispatcher::Dispatcher;

src/reducer.rs

@@ -1,4 +1,5 @@
-use crate::ActionWithMeta;
+use crate::{ActionWithMeta, Dispatcher};
 
 /// Function signature for a reducer.
-pub type Reducer<State, Action> = fn(&mut State, &ActionWithMeta<Action>);
+pub type Reducer<State, Action> =
+    fn(&mut State, &ActionWithMeta<Action>, &mut Dispatcher<Action, State>);

src/store.rs

@@ -1,8 +1,8 @@
 use std::sync::OnceLock;
 
 use crate::{
-    ActionId, ActionMeta, ActionWithMeta, Effects, EnablingCondition, Instant, Reducer, SubStore,
-    SystemTime, TimeService,
+    ActionId, ActionMeta, ActionWithMeta, Dispatcher, Effects, EnablingCondition, Instant, Reducer,
+    SubStore, SystemTime, TimeService,
 };
 
 /// Wraps around State and allows only immutable borrow,
@@ -75,11 +75,15 @@ pub struct Store<State, Service, Action> {
     recursion_depth: u32,
 
     last_action_id: ActionId,
+
+    /// Queue for actions to be dispatched after the state update
+    dispatch_queue: Dispatcher<Action, State>,
 }
 
 impl<State, Service, Action> Store<State, Service, Action>
 where
     Service: TimeService,
+    Action: EnablingCondition<State>,
 {
     /// Creates a new store.
     pub fn new(
@@ -109,6 +113,8 @@ where
 
             recursion_depth: 0,
             last_action_id: ActionId::new_unchecked(initial_time_nanos as u64),
+
+            dispatch_queue: Dispatcher::new(),
         }
     }
 
@@ -186,6 +192,7 @@ where
         self.last_action_id = curr;
         self.recursion_depth += 1;
 
+        // TODO: instead return queued actions and pass them to dispatch_effects?
         self.dispatch_reducer(&action_with_meta);
         self.dispatch_effects(action_with_meta);
 
@@ -195,21 +202,34 @@ where
     /// Runs the reducer.
     #[inline(always)]
     fn dispatch_reducer(&mut self, action_with_id: &ActionWithMeta<Action>) {
-        (self.reducer)(self.state.get_mut(), action_with_id);
+        // All new queued elements will be stored here
+        let mut queue = Dispatcher::new();
+        (self.reducer)(self.state.get_mut(), action_with_id, &mut queue);
+
+        // All the enqueued actions gets pushed to the front of the global queue
+        self.dispatch_queue.push_front(queue);
     }
 
     /// Runs the effects.
     #[inline(always)]
     fn dispatch_effects(&mut self, action_with_id: ActionWithMeta<Action>) {
+        // First the effects for this specific action must be handled
         (self.effects)(self, action_with_id);
+
+        // Then dispatch all actions enqueued by the reducer
+        while let Some(action) = self.dispatch_queue.pop() {
+            if action.is_enabled(self.state(), self.last_action_id.into()) {
+                self.dispatch_enabled(action);
+            }
+        }
     }
 }
 
 impl<State, Service, Action> Clone for Store<State, Service, Action>
 where
     State: Clone,
     Service: Clone,
-    Action: Clone,
+    Action: Clone + EnablingCondition<State>,
 {
     fn clone(&self) -> Self {
         Self {
@@ -222,6 +242,8 @@ where
 
             recursion_depth: self.recursion_depth,
             last_action_id: self.last_action_id,
+
+            dispatch_queue: Dispatcher::new(), // TODO: clone
         }
     }
 }