rx_core_common 0.2.2

rx_core's core traits and implementations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use std::ops::{Deref, DerefMut};

use crate::{Observable, Signal};
use derive_where::derive_where;
use variadics_please::all_tuples;

use super::ErasedObservable;

#[derive_where(Clone)]
pub struct ErasedObservables<Out, OutError, const SIZE: usize>
where
	Out: Signal,
	OutError: Signal,
{
	observables: [ErasedObservable<Out, OutError>; SIZE],
}

impl<Out, OutError, const SIZE: usize> Deref for ErasedObservables<Out, OutError, SIZE>
where
	Out: Signal,
	OutError: Signal,
{
	type Target = [ErasedObservable<Out, OutError>; SIZE];

	fn deref(&self) -> &Self::Target {
		&self.observables
	}
}

impl<Out, OutError, const SIZE: usize> DerefMut for ErasedObservables<Out, OutError, SIZE>
where
	Out: Signal,
	OutError: Signal,
{
	fn deref_mut(&mut self) -> &mut Self::Target {
		&mut self.observables
	}
}

impl<Out, OutError, const SIZE: usize, O> From<[O; SIZE]> for ErasedObservables<Out, OutError, SIZE>
where
	Out: 'static + Signal,
	OutError: 'static + Signal,
	O: 'static + Observable<Out = Out, OutError = OutError> + Send + Sync,
{
	fn from(value: [O; SIZE]) -> Self {
		Self {
			observables: value.map(|observable| ErasedObservable::new(observable)),
		}
	}
}

macro_rules! tuple_len {
	() => { 0usize };
	(@one $name:ident) => { 1usize };
	($($name:ident),+) => {
		0usize $(+ tuple_len!(@one $name))*
	};
}

macro_rules! impl_tuple_erased_observable {
	($(#[$meta:meta])* $($name:ident),*) => {
		$(#[$meta])*
		impl<
			Out: 'static + Signal,
			OutError: 'static + Signal,
			$($name: 'static + Observable<Out = Out, OutError = OutError> + Send + Sync),*
		> From<($($name,)*)> for ErasedObservables<Out, OutError, { tuple_len!($($name),*) }>
		{
			fn from(value: ($($name,)*)) -> Self {
				#[allow(non_snake_case)]
				let ($($name,)*) = value;

				Self {
					observables: [
						$(ErasedObservable::new($name),)*
					],
				}
			}
		}
	};
}

all_tuples!(impl_tuple_erased_observable, 1, 15, O);