reactivate/
macros.rs

1use crate::{Merge, Reactive};
2use paste::paste;
3
4impl<
5        #[cfg(not(feature = "threadsafe"))] T: Clone + Default + 'static,
6        #[cfg(feature = "threadsafe")] T: Clone + Default + Send + 'static,
7    > Merge for &Reactive<T>
8{
9    type Output = T;
10    fn merge(self) -> Reactive<Self::Output> {
11        self.clone()
12    }
13}
14
15#[cfg(not(feature = "threadsafe"))]
16macro_rules! impl_merge_for_nested_tuple {
17    ( $($i:literal),* ) => { paste!{
18    impl < $( [<T $i>], )* > Merge for ( $( [<T $i>], )* )
19    where
20        $( [<T $i>]: Merge, ) *
21        $( [<T $i>]::Output: Clone + Default + 'static, ) *
22    {
23        body!($($i),*);
24    }
25    }};
26}
27
28#[cfg(feature = "threadsafe")]
29macro_rules! impl_merge_for_nested_tuple {
30    ( $($i:literal),* ) => { paste!{
31    impl < $( [<T $i>], )* > Merge for ( $( [<T $i>], )* )
32    where
33        $( [<T $i>]: Merge, ) *
34        $( [<T $i>]::Output: Clone + Default + Send + 'static, ) *
35    {
36        body!($($i),*);
37    }
38    }};
39}
40
41macro_rules! body {
42    ( $($i:literal),* ) => {paste!{
43        type Output = ( $([<T $i>]::Output,)* );
44
45        fn merge(self) -> Reactive<Self::Output> {
46            let reactives = ( $(self.$i.merge(),)* );
47            let values = ( $(reactives.$i.value(),)* );
48            let combined = Reactive::new(values);
49
50            $( reactives.$i.add_observer({
51                let combined = combined.clone();
52                // we know for sure that the value inside 'combined' did change
53                // because 'combined' stores the reactive values as-is without any transformation
54                // eg: (&Reactive<String>, &Reactive<usize>, ...) -> Reactive<(String, usize, ...)>
55                // so if the parent reactive changes, the 'combined' will definitely change.
56                // Therefore 'unchecked' is fine.
57                move |val| combined.update_inplace_unchecked(|c| c.$i = val.clone())
58            }); )*
59
60            combined
61        }
62    }};
63}
64
65impl_merge_for_nested_tuple!(0);
66impl_merge_for_nested_tuple!(0, 1);
67impl_merge_for_nested_tuple!(0, 1, 2);
68impl_merge_for_nested_tuple!(0, 1, 2, 3);
69impl_merge_for_nested_tuple!(0, 1, 2, 3, 4);
70impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5);
71impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6);
72impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7);
73impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8);
74impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9);
75impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
76impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11);
77impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12);
78impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13);
79impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14);
80impl_merge_for_nested_tuple!(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15);
reactivate/macros.rs

reactivate/
macros.rs
