feat: Reducer traits (#18)

Author: marc2332

Cargo.lock

@@ -6,6 +6,31 @@ struct Data {
     pub lists: Vec<Vec<String>>,
 }
 
+pub enum ChannelAction {
+    NewList,
+    AddToList { list: usize, text: String },
+}
+
+impl DataReducer for Data {
+    type Action = ChannelAction;
+    type Channel = DataChannel;
+
+    fn reduce(&mut self, message: Self::Action) -> Self::Channel {
+        match message {
+            ChannelAction::NewList => {
+                self.lists.push(Vec::default());
+
+                DataChannel::ListCreated
+            }
+            ChannelAction::AddToList { list, text } => {
+                self.lists[list].push(text);
+
+                DataChannel::ListN(list)
+            }
+        }
+    }
+}
+
 #[derive(PartialEq, Eq, Clone, Debug)]
 pub enum DataChannel {
     ListCreated,
@@ -20,7 +45,7 @@ fn main() {
         let mut radio = use_radio::<Data, DataChannel>(DataChannel::ListCreated);
 
         let onclick = move |_| {
-            radio.write().lists.push(Vec::default());
+            radio.apply(ChannelAction::NewList);
         };
 
         println!("Running DataChannel::ListCreated");
@@ -49,7 +74,10 @@ fn ListComp(list_n: usize) -> Element {
     rsx!(
         div {
             button {
-                onclick: move |_| radio.write().lists[list_n].push("Hello World".to_string()),
+                onclick: move |_| radio.apply(ChannelAction::AddToList {
+                    list: 0,
+                    text: "Hello, World".to_string()
+                }),
                 "New Item"
             },
             ul {

examples/demo.rs

@@ -357,17 +357,14 @@ where
     ///     }
     /// });
     /// ```
-    pub fn write_with_map_channel(
-        &mut self,
-        cb: impl FnOnce(&mut RadioGuard<Value, Channel>) -> Channel,
-    ) {
+    pub fn write_with_map_channel(&mut self, cb: impl FnOnce(&mut Value) -> Channel) {
         let value = self.antenna.peek().station.value.write_unchecked();
         let mut guard = RadioGuard {
             channels: Vec::default(),
             antenna: self.antenna,
             value,
         };
-        let channel = cb(&mut guard);
+        let channel = cb(&mut guard.value);
         for channel in channel.derive_channel(&guard.value) {
             self.antenna.peek().station.notify_listeners(&channel)
         }
@@ -419,3 +416,29 @@ where
 {
     use_context::<RadioStation<Value, Channel>>()
 }
+
+pub trait DataReducer {
+    type Channel;
+    type Action;
+
+    fn reduce(&mut self, action: Self::Action) -> Self::Channel;
+}
+
+pub trait RadioReducer {
+    type Action;
+
+    fn apply(&mut self, action: Self::Action);
+}
+
+impl<
+        Data: DataReducer<Channel = Channel, Action = Action>,
+        Channel: RadioChannel<Data>,
+        Action,
+    > RadioReducer for Radio<Data, Channel>
+{
+    type Action = Action;
+
+    fn apply(&mut self, action: Action) {
+        self.write_with_map_channel(|data| data.reduce(action));
+    }
+}