observable_deferred

Subscribes to an observable returned by a function.

See Also

• CreateObservable - Define your own function that will interact with the subscriber!
• JustObservable - Immediately emits a single value!
• EmptyObservable - Immediately completes!
• ThrowObservable - Immediately errors!
• ClosedObservable - Immediately unsubscribes!
• NeverObservable - Never emits, never unsubscribes! Only once dropped!

Example

cargo run -p rx_core --example observable_deferred_example

let i = RefCell::new(1);
let mut deferred = deferred_observable(|| {
  println!("subscribe!");
  (0..=*i.borrow()).into_observable()
});

*i.borrow_mut() = 2;
let _subscription = deferred.subscribe(PrintObserver::new("deferred_observable"));

Output:

subscribe!
deferred_observable - next: 0
deferred_observable - next: 1
deferred_observable - next: 2
deferred_observable - completed
deferred_observable - unsubscribed