rxrust 0.4.0

A Rust implementation of Reactive Extensions.
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

pub mod map;
pub use map::Map;
pub mod filter;
pub use filter::Filter;
pub mod merge;
pub use merge::Merge;
pub mod take;
pub use take::Take;
pub mod first;
pub use first::{First, FirstOr};
pub mod fork;
pub use fork::Fork;
pub mod subscribe_on;
pub use subscribe_on::SubscribeOn;
pub mod observe_on;
pub use observe_on::ObserveOn;
pub mod delay;
pub use delay::Delay;
pub mod throttle_time;
pub use throttle_time::{ThrottleEdge, ThrottleTime};
pub mod publish;
pub use publish::Publish;
pub mod ref_count;

use crate::prelude::*;
pub struct SharedOp<T>(pub(crate) T);

impl<Item, Err, S, OP> RawSubscribable<Item, Err, S> for SharedOp<OP>
where
  OP: RawSubscribable<Item, Err, S::Shared>,
  S: IntoShared,
{
  type Unsub = OP::Unsub;
  fn raw_subscribe(self, subscriber: S) -> Self::Unsub {
    self.0.raw_subscribe(subscriber.to_shared())
  }
}

impl<OP> Fork for SharedOp<OP>
where
  OP: Fork,
{
  type Output = SharedOp<OP::Output>;
  fn fork(&self) -> Self::Output { SharedOp(self.0.fork()) }
}

impl<S> IntoShared for SharedOp<S>
where
  S: IntoShared + Send + Sync + 'static,
{
  type Shared = SharedOp<S::Shared>;
  #[inline(always)]
  fn to_shared(self) -> Self::Shared { SharedOp(self.0.to_shared()) }
}