Add aper-leptos

Cargo.toml

@@ -6,10 +6,12 @@ exclude = [
 ]
 
 members = [
-    "aper",
-    "aper/aper-derive*",
-    "aper-websocket-client",
+    "aper-leptos",
     "aper-serve",
     "aper-stateroom",
-    "site/doctests", "aper-yew",
+    "aper-websocket-client",
+    "aper-yew",
+    "aper",
+    "aper/aper-derive*",
+    "site/doctests",
 ]

aper-leptos/Cargo.toml

@@ -0,0 +1,12 @@
+[package]
+name = "aper-leptos"
+version = "0.5.0"
+edition = "2021"
+
+[dependencies]
+aper = {path = "../aper"}
+aper-websocket-client = { version="0.5.0", path="../aper-websocket-client" }
+leptos = { version = "0.6.14", features = ["csr"] }
+serde = "1.0.210"
+tracing-subscriber = "0.3.18"
+tracing-web = "0.1.3"

aper-leptos/src/lib.rs

@@ -0,0 +1,26 @@
+use aper::{data_structures::Atom, AperSync};
+use leptos::{create_signal, SignalGet, SignalSet};
+use serde::{de::DeserializeOwned, Serialize};
+
+pub mod init_tracing;
+
+pub trait Watch<T> {
+    fn watch(&self) -> Box<dyn Fn() -> T>;
+}
+
+impl<T> Watch<T> for Atom<T>
+where
+    T: Serialize + DeserializeOwned + Default + Clone + Send + Sync + 'static,
+{
+    fn watch(&self) -> Box<dyn Fn() -> T> {
+        let (signal, set_signal) = create_signal(self.get());
+
+        let self_clone = self.clone();
+        self.listen(move || {
+            set_signal.set(self_clone.get());
+            true
+        });
+
+        Box::new(move || signal.get())
+    }
+}