rx_core_operator_map 0.2.0

map operator for rx_core
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

use core::marker::PhantomData;

use derive_where::derive_where;
use rx_core_common::{PhantomInvariant, RxObserver, Signal, Subscriber};
use rx_core_macro_subscriber_derive::RxSubscriber;

#[derive_where(Debug)]
#[derive_where(skip_inner(Debug))]
#[derive(RxSubscriber)]
#[rx_in(In)]
#[rx_in_error(InError)]
#[rx_delegate_teardown_collection]
#[rx_delegate_subscription_like_to_destination]
pub struct MapSubscriber<In, InError, Mapper, Out, Destination>
where
	In: Signal,
	InError: Signal,
	Mapper: Fn(In) -> Out + Send + Sync,
	Out: Signal,
	Destination: Subscriber<In = Out, InError = InError>,
{
	#[destination]
	destination: Destination,
	mapper: Mapper,
	_phantom_data: PhantomInvariant<(In, InError, Out)>,
}

impl<In, InError, Mapper, Out, Destination> MapSubscriber<In, InError, Mapper, Out, Destination>
where
	In: Signal,
	InError: Signal,
	Mapper: Fn(In) -> Out + Send + Sync,
	Out: Signal,
	Destination: Subscriber<In = Out, InError = InError>,
{
	pub fn new(destination: Destination, mapper: Mapper) -> Self {
		Self {
			destination,
			mapper,
			_phantom_data: PhantomData,
		}
	}
}

impl<In, InError, Mapper, Out, Destination> RxObserver
	for MapSubscriber<In, InError, Mapper, Out, Destination>
where
	In: Signal,
	InError: Signal,
	Mapper: Fn(In) -> Out + Send + Sync,
	Out: Signal,
	Destination: Subscriber<In = Out, InError = InError>,
{
	#[inline]
	fn next(&mut self, next: Self::In) {
		self.destination.next((self.mapper)(next));
	}

	#[inline]
	fn error(&mut self, error: Self::InError) {
		self.destination.error(error);
	}

	#[inline]
	fn complete(&mut self) {
		self.destination.complete();
	}
}