another-rxrust 0.0.46

A different implementation than `rxRust` for easier use of `ReactiveX` in `Rust`.
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

#[macro_export]
macro_rules! junk_next (
  () => ( |_| {} )
);

#[macro_export]
macro_rules! junk_error (
  () => ( |_| {} )
);

#[macro_export]
macro_rules! junk_complete (
  () => ( || {} )
);

#[macro_export]
macro_rules! panic_error (
  () => ( |e| { panic!("{:?}", e); } )
);

#[macro_export]
macro_rules! print_next (
  () => ( |_| { println!("next"); } )
);

#[macro_export]
macro_rules! print_next_fmt (
  ($e: expr) => ( |x| { println!("next - {}", format!($e, x)); } )
);

#[macro_export]
macro_rules! print_error (
  () => ( |e| { println!("error - {:?}", e); } )
);

#[macro_export]
macro_rules! print_complete (
  () => ( || { println!("complete"); } )
);

#[macro_export]
macro_rules! print_error_as (
  ($t: ty) => ( |e| { println!("error - {:?}", e.downcast_ref::<$t>()); } )
);