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) }