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

/// Returns a ConnectableObservable. A ConnectableObservable Observable
/// resembles an ordinary Observable, except that it does not begin emitting
/// items when it is subscribed to, but only when the Connect operator is
/// applied to it. In this way you can wait for all intended observers to
/// subscribe to the Observable before the Observable begins emitting items.
///
use crate::observable::connectable_observable::LocalConnectableObservable;
pub use crate::prelude::*;

pub trait Publish<'a, Item, Err>
where
  Self: Sized,
{
  #[inline(always)]
  fn publish(self) -> LocalConnectableObservable<'a, Self, Item, Err> {
    LocalConnectableObservable::local(self)
  }
}

impl<'a, Item, Err, T> Publish<'a, Item, Err> for T {}

#[test]
fn smoke() {
  use crate::observable::Connect;
  let p = observable::of!(100).publish();
  let mut first = 0;
  let mut second = 0;
  p.fork().subscribe(|v| first = *v);
  p.fork().subscribe(|v| second = *v);

  p.connect();
  assert_eq!(first, 100);
  assert_eq!(second, 100);
}