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

mod creation;
mod creation_success;
mod do_finally;
mod do_on_error;
mod error;
mod filter;
mod flatmap;
mod foreach;
mod just;
mod misc;
mod do_on_complete;
mod schedule_on;
mod spi;
mod transform;

pub use creation::MonoCreate;
pub use creation_success::MonoCreateSuccess;
pub use do_finally::MonoDoFinally;
pub use do_on_error::MonoDoOnError;
pub use error::MonoError;
pub use filter::MonoFilter;
pub use flatmap::MonoFlatMap;
pub use foreach::Foreach;
pub use just::MonoJust;
pub use do_on_complete::MonoDoOnComplete;
pub use schedule_on::*;
pub use spi::Mono;
pub use transform::MonoTransform;

pub fn success<T, G>(gen: G) -> MonoCreateSuccess<T, G>
where
  G: Fn() -> T,
{
  MonoCreateSuccess::new(gen)
}

pub fn create<T, G, E>(gen: G) -> MonoCreate<T, G, E>
where
  G: Fn() -> Result<T, E>,
{
  MonoCreate::new(gen)
}

pub fn just<T>(t: T) -> MonoJust<T, ()>
where
  T: Clone,
{
  MonoJust::new(t)
}

pub fn error<E>(e: E) -> MonoError<E> {
  MonoError::new(e)
}