Module rxrust::observable [−][src]
Re-exports
pub use of::of;pub use of::of_fn;pub use of::of_option;pub use of::of_result;pub use interval::interval;pub use interval::interval_at;pub use from_fn::*;pub use timer::timer;pub use timer::timer_at;Modules
Structs
Traits
Functions
Creates an observable that will on subscription defer to another observable that is supplied by a supplier-function which will be run once at each subscription
Creates an observable that produces no values.
Converts a Future to an observable sequence. Even though if the future
poll value has Result::Err type, also emit as a normal value, not trigger
to error handle.
Converts a Future to an observable sequence like
[from_future@from_future]. But only work for which Future::Output is
Result type, and Result::Ok emit to next handle, and Result::Err as an
error to handle.
Creates an observable that produces values from an iterator.
Creates an observable that never emits anything.
Creates an observable producing same value repeated N times.
Creates an observable that emits no items, just terminates with an error.