[−][src]Module rxrust::observable

Re-exports

pub use ops::SharedOp;

interval	Creates an observable which will fire at `dur` time into the future, and will repeat every `dur` interval after.
interval_at	Creates a observable which will fire at the time specified by `at`, and then will repeat every `dur` interval after

ForkObservable
LocalConnectableObservable
Observable	A representation of any set of values over any amount of time. This is the most basic building block rxrust
SharedConnectableObservable
SharedForkObservable

empty	Creates an observable that produces no values.
from_fn	Creates an observable that emits the return value of a callable.
from_future	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.
from_future_with_err	Converts a `Future` to an observable sequence like `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.
from_iter	Creates an observable that produces values from an iterator.
never	Creates an observable that never emitts anything.
of	Creates an observable producing a single value.
of_option	Creates an observable that potentially emits a single value from `Option`.
of_result	Creates an observable that emits value or the error from a `Result` given.
repeat	Creates an observable producing same value repeated N times.
throw	Creates an observable that emitts no items, just terminates with an error.