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 timer::timer;pub use timer::timer_at;pub use from_fn::*;
Modules§
Structs§
- Connectable
Observable - Defer
Emitter - Empty
Emitter - Never
Emitter - Observable
Base - Observer
All - Observer
Comp - Observer
Err - ObserverN
- Throw
Emitter
Traits§
Functions§
- defer
- 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
- empty
- Creates an observable that produces no values.
- from_
future - Converts a
Futureto an observable sequence. Even though if the future poll value hasResult::Errtype, also emit as a normal value, not trigger to error handle. - from_
future_ result - Converts a
Futureto an observable sequence like [from_future@from_future]. But only work for whichFuture::OutputisResulttype, andResult::Okemit to next handle, andResult::Erras an error to handle. - from_
iter - Creates an observable that produces values from an iterator.
- never
- Creates an observable that never emits anything.
- repeat
- Creates an observable producing same value repeated N times.
- throw
- Creates an observable that emits no items, just terminates with an error.