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 |
from_future_result | Converts a |
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 |
of_result | Creates an observable that emits value or the error from a |
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 |