observable_empty
Immediately completes.
See Also
- CreateObservable - Define your own function that will interact with the subscriber!
- DeferredObservable - Subscribes to an observable returned by a function.
- JustObservable - Immediately emits a single value!
- ThrowObservable - Immediately errors!
- ClosedObservable - Immediately unsubscribes!
- NeverObservable - Never emits, never unsubscribes! Only once dropped!
Example
cargo run -p rx_core --example observable_empty_example
let _subscription = empty().subscribe(PrintObserver::new("empty"));
Output:
empty - completed
empty - unsubscribed