thaw_utils/signals/
component_ref.rs

1use leptos::{
2    logging::debug_warn,
3    prelude::{
4        ArcReadSignal, ArcRwSignal, ArcWriteSignal, Get, GetUntracked, RwSignal, Storage,
5        SyncStorage, Update,
6    },
7};
8
9pub struct ComponentRef<T, S = SyncStorage>(RwSignal<Option<T>, S>);
10
11impl<T> Default for ComponentRef<T>
12where
13    T: Send + Sync + 'static,
14{
15    fn default() -> Self {
16        Self(RwSignal::new(None))
17    }
18}
19
20impl<T, S> Clone for ComponentRef<T, S> {
21    fn clone(&self) -> Self {
22        Self(self.0.clone())
23    }
24}
25
26impl<T, S> Copy for ComponentRef<T, S> {}
27
28impl<T> ComponentRef<T>
29where
30    T: Send + Sync + 'static,
31{
32    pub fn new() -> Self {
33        Self::default()
34    }
35}
36
37impl<T, S> ComponentRef<T, S>
38where
39    T: Clone + 'static,
40    S: Storage<ArcRwSignal<Option<T>>> + Storage<ArcReadSignal<Option<T>>>,
41{
42    pub fn get(&self) -> Option<T> {
43        self.0.get()
44    }
45
46    pub fn get_untracked(&self) -> Option<T> {
47        self.0.get_untracked()
48    }
49}
50
51impl<T, S> ComponentRef<T, S>
52where
53    T: 'static,
54    S: Storage<ArcRwSignal<Option<T>>> + Storage<ArcWriteSignal<Option<T>>>,
55{
56    pub fn load(&self, comp: T) {
57        self.0.update(|current| {
58            if current.is_some() {
59                debug_warn!(
60                    "You are setting a ComponentRef that has already been filled. \
61                     It’s possible this is intentional."
62                );
63            }
64            *current = Some(comp);
65        });
66    }
67
68    // pub fn on_load<F>(self, f: F)
69    // where
70    //     T: Clone,
71    //     F: FnOnce(T) + 'static,
72    // {
73    //     let f = Cell::new(Some(f));
74
75    //     RenderEffect::new(move |_| {
76    //         if let Some(comp) = self.get() {
77    //             f.take().unwrap()(comp);
78    //         }
79    //     });
80    // }
81}
thaw_utils/signals/component_ref.rs

thaw_utils/signals/
component_ref.rs
