[−][src]Module rxrust::observable

Re-exports

pub use from_fn::*;

empty	Creates an observable that produces no values.
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_result	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.
from_iter	Creates an observable that produces values from an iterator.
interval	Creates an observable which will fire at `dur` time into the future, and will repeat every `dur` interval after.
interval_at	Creates an observable which will fire at the time specified by `at`, and then will repeat every `dur` interval after
never	Creates an observable that never emits anything.
of	Creates an observable producing a single value.
of_fn	Creates an observable that emits the return value of a callable.
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 emits no items, just terminates with an error.

LocalConnectableObservable
SharedConnectableObservable