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

use crate::{
	Observable, ObservableOutput, OptionSubscription, UpgradeableObserver, WithPrimaryCategory,
};

impl<O> ObservableOutput for Option<O>
where
	O: ObservableOutput,
{
	type Out = O::Out;
	type OutError = O::OutError;
}

impl<O> WithPrimaryCategory for Option<O>
where
	O: WithPrimaryCategory,
{
	type PrimaryCategory = O::PrimaryCategory;
}

impl<O> Observable for Option<O>
where
	O: Observable,
{
	type Subscription<Destination>
		= OptionSubscription<O::Subscription<<Destination as UpgradeableObserver>::Upgraded>>
	where
		Destination: 'static + crate::Subscriber<In = Self::Out, InError = Self::OutError>;

	fn subscribe<Destination>(
		&mut self,
		destination: Destination,
	) -> Self::Subscription<Destination::Upgraded>
	where
		Destination: 'static
			+ crate::UpgradeableObserver<In = Self::Out, InError = Self::OutError>
			+ Send
			+ Sync,
	{
		OptionSubscription::new(self.as_mut().map(|obs| obs.subscribe(destination)))
	}
}