observable_closed

An observable that immediately closes without completing or emitting any values.

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!
• EmptyObservable - Immediately completes!
• ThrowObservable - Immediately errors!
• NeverObservable - Never emits, never unsubscribes! Only once dropped!

Example

cargo run -p rx_core --example observable_closed_example

let _subscription = closed().subscribe(PrintObserver::new("closed"));
println!("end");

Output:

closed - unsubscribed
end