fix: Expose App::mailbox; rerender VDOM on handler invocation without Msg

Author: MartinKavik

CHANGELOG.md

@@ -49,7 +49,8 @@
 - [BREAKING] Renamed `to_kbevent` to `to_keyboard_event`.
 - [BREAKING] `after_next_render` returns `RenderInfo`.
 - `web_sys` and `wasm_bindgen` available in `seed::web_sys` and `seed::wasm_bindgen`.
-- Added `WebSocket`.
+- Added `WebSocket` + related items.
+- Exposed `App::mailbox`.
 
 ## v0.6.0
 - Implemented `UpdateEl` for `Filter` and `FilterMap`.

src/app.rs

@@ -556,7 +556,7 @@ impl<Ms, Mdl, INodes: IntoNodes<Ms> + 'static, GMs: 'static> App<Ms, Mdl, INodes
         );
     }
 
-    fn mailbox(&self) -> Mailbox<Ms> {
+    pub fn mailbox(&self) -> Mailbox<Ms> {
         Mailbox::new(enclose!((self => s) move |option_message| {
             if let Some(message) = option_message {
                 s.update(message);

src/app/orders/container.rs

@@ -81,11 +81,7 @@ impl<Ms: 'static, Mdl, INodes: IntoNodes<Ms> + 'static, GMs: 'static> Orders<Ms,
             Box
         );
 
-        let cmd = cmd.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(msg)
-            }
-        });
+        let cmd = cmd.map(move |msg| app.mailbox().send(handler(msg)));
         CmdManager::perform_cmd(cmd);
         self
     }
@@ -103,11 +99,7 @@ impl<Ms: 'static, Mdl, INodes: IntoNodes<Ms> + 'static, GMs: 'static> Orders<Ms,
             Box
         );
 
-        let cmd = cmd.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(msg)
-            }
-        });
+        let cmd = cmd.map(move |msg| app.mailbox().send(handler(msg)));
         CmdManager::perform_cmd_with_handle(cmd)
     }
 
@@ -204,11 +196,7 @@ impl<Ms: 'static, Mdl, INodes: IntoNodes<Ms> + 'static, GMs: 'static> Orders<Ms,
             Box
         );
 
-        let stream = stream.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(msg)
-            }
-        });
+        let stream = stream.map(move |msg| app.mailbox().send(handler(msg)));
         StreamManager::stream(stream);
         self
     }
@@ -226,11 +214,7 @@ impl<Ms: 'static, Mdl, INodes: IntoNodes<Ms> + 'static, GMs: 'static> Orders<Ms,
             Box
         );
 
-        let stream = stream.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(msg)
-            }
-        });
+        let stream = stream.map(move |msg| app.mailbox().send(handler(msg)));
         StreamManager::stream_with_handle(stream)
     }
 }

src/app/orders/proxy.rs

@@ -94,11 +94,7 @@ impl<'a, Ms: 'static, AppMs: 'static, Mdl, INodes: IntoNodes<AppMs> + 'static, G
             Box
         );
 
-        let cmd = cmd.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(f(msg))
-            }
-        });
+        let cmd = cmd.map(move |msg| app.mailbox().send(handler(msg).map(|msg| f(msg))));
         CmdManager::perform_cmd(cmd);
         self
     }
@@ -117,11 +113,7 @@ impl<'a, Ms: 'static, AppMs: 'static, Mdl, INodes: IntoNodes<AppMs> + 'static, G
             Box
         );
 
-        let cmd = cmd.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(f(msg))
-            }
-        });
+        let cmd = cmd.map(move |msg| app.mailbox().send(handler(msg).map(|msg| f(msg))));
         CmdManager::perform_cmd_with_handle(cmd)
     }
 
@@ -224,11 +216,7 @@ impl<'a, Ms: 'static, AppMs: 'static, Mdl, INodes: IntoNodes<AppMs> + 'static, G
             Box
         );
 
-        let stream = stream.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(f(msg))
-            }
-        });
+        let stream = stream.map(move |msg| app.mailbox().send(handler(msg).map(|msg| f(msg))));
         StreamManager::stream(stream);
         self
     }
@@ -247,11 +235,7 @@ impl<'a, Ms: 'static, AppMs: 'static, Mdl, INodes: IntoNodes<AppMs> + 'static, G
             Box
         );
 
-        let stream = stream.map(move |msg| {
-            if let Some(msg) = handler(msg) {
-                app.update(f(msg))
-            }
-        });
+        let stream = stream.map(move |msg| app.mailbox().send(handler(msg).map(|msg| f(msg))));
         StreamManager::stream_with_handle(stream)
     }
 }

src/browser/web_socket/builder.rs

@@ -177,11 +177,9 @@ fn create_js_handler<T: wasm_bindgen::convert::FromWasmAbi + 'static, Ms: 'stati
     orders: &impl Orders<Ms>,
 ) -> Closure<dyn Fn(T)> {
     let (app, msg_mapper) = (orders.clone_app(), orders.msg_mapper());
-
+    let mailbox = app.mailbox();
     // @TODO replace with `Closure::new` once stable.
     Closure::wrap(Box::new(move |data| {
-        if let Some(msg) = handler(data) {
-            app.update(msg_mapper(msg))
-        }
+        mailbox.send(handler(data).map(|msg| msg_mapper(msg)));
     }) as Box<dyn Fn(T)>)
 }