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
85
86
87
88
89
90
91
92

use rx_core_macro_subscriber_derive::RxSubscriber;

use crate::{RxObserver, Subscriber, SubscriptionLike, Teardown, TeardownCollection};

#[derive(RxSubscriber)]
#[_rx_core_common_crate(crate)]
#[rx_in(InnerSubscriber::In)]
#[rx_in_error(InnerSubscriber::InError)]
pub enum OptionSubscriber<InnerSubscriber, Destination>
where
	InnerSubscriber: Subscriber,
	Destination: Subscriber<In = InnerSubscriber::In, InError = InnerSubscriber::InError>,
{
	Some(InnerSubscriber),
	None(Destination),
}

impl<InnerSubscriber, Destination> RxObserver for OptionSubscriber<InnerSubscriber, Destination>
where
	InnerSubscriber: Subscriber,
	Destination: Subscriber<In = InnerSubscriber::In, InError = InnerSubscriber::InError>,
	InnerSubscriber::In: 'static,
	InnerSubscriber::InError: 'static,
{
	fn next(&mut self, next: Self::In) {
		match self {
			OptionSubscriber::Some(internal_subscriber) => internal_subscriber.next(next),
			OptionSubscriber::None(fallback_subscriber) => fallback_subscriber.next(next),
		}
	}

	fn error(&mut self, error: Self::InError) {
		match self {
			OptionSubscriber::Some(internal_subscriber) => internal_subscriber.error(error),
			OptionSubscriber::None(fallback_subscriber) => fallback_subscriber.error(error),
		}
	}

	fn complete(&mut self) {
		match self {
			OptionSubscriber::Some(internal_subscriber) => internal_subscriber.complete(),
			OptionSubscriber::None(fallback_subscriber) => fallback_subscriber.complete(),
		}
	}
}

impl<InnerSubscriber, Destination> SubscriptionLike
	for OptionSubscriber<InnerSubscriber, Destination>
where
	InnerSubscriber: Subscriber,
	Destination: Subscriber<In = InnerSubscriber::In, InError = InnerSubscriber::InError>,
	InnerSubscriber::In: 'static,
	InnerSubscriber::InError: 'static,
{
	fn is_closed(&self) -> bool {
		match self {
			OptionSubscriber::Some(internal_subscriber) => internal_subscriber.is_closed(),
			OptionSubscriber::None(fallback_subscriber) => fallback_subscriber.is_closed(),
		}
	}

	fn unsubscribe(&mut self) {
		match self {
			OptionSubscriber::Some(internal_subscriber) => {
				internal_subscriber.unsubscribe();
			}
			OptionSubscriber::None(fallback_subscriber) => {
				fallback_subscriber.unsubscribe();
			}
		}
	}
}

impl<InnerSubscriber, Destination> TeardownCollection
	for OptionSubscriber<InnerSubscriber, Destination>
where
	InnerSubscriber: Subscriber,
	Destination: Subscriber<In = InnerSubscriber::In, InError = InnerSubscriber::InError>,
	InnerSubscriber::In: 'static,
	InnerSubscriber::InError: 'static,
{
	fn add_teardown(&mut self, teardown: Teardown) {
		match self {
			OptionSubscriber::Some(internal_subscriber) => {
				internal_subscriber.add_teardown(teardown);
			}
			OptionSubscriber::None(fallback_subscriber) => {
				fallback_subscriber.add_teardown(teardown);
			}
		}
	}
}