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

use derive_where::derive_where;
use rx_core_macro_subscriber_derive::RxSubscriber;

use crate::{Signal, Subscriber, subscribers::subscriber_box::BoxedSubscriber};

#[derive_where(Debug)]
#[derive(RxSubscriber)]
#[_rx_core_common_crate(crate)]
#[rx_in(In)]
#[rx_in_error(InError)]
#[rx_delegate_observer_to_destination]
#[rx_delegate_subscription_like_to_destination]
#[rx_delegate_teardown_collection]
pub struct ErasedSubscriber<In, InError>
where
	In: Signal,
	InError: Signal,
{
	#[derive_where(skip(Debug))]
	#[destination]
	destination: BoxedSubscriber<In, InError>,
}

impl<In, InError> ErasedSubscriber<In, InError>
where
	In: Signal,
	InError: Signal,
{
	pub fn new<Destination>(destination: Destination) -> Self
	where
		Destination: 'static + Subscriber<In = In, InError = InError> + Send + Sync,
	{
		Self {
			destination: Box::new(destination),
		}
	}
}