Module rxrust::observable[][src]

Re-exports

pub use interval::interval;
pub use interval::interval_at;
pub use from_fn::*;

Modules

from_fn
interval

Macros

of_sequence

Creates an observable producing a multiple values.

Structs

ConnectableObservable
EmptyEmitter
NeverEmitter
ObservableBase
ObserverAll
ObserverComp
ObserverErr
ObserverN
ThrowEmitter

Traits

Emitter
LocalEmitter
LocalObservable
Observable
SubscribeAll
SubscribeComplete
SubscribeErr
SubscribeNext

Functions

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.

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.

Type Definitions

LocalConnectableObservable
SharedConnectableObservable