observable_just

Immediately emits a single value.

See Also

• CreateObservable - Define your own function that will interact with the subscriber!
• DeferredObservable - Subscribes to an observable returned by a function.
• 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_just_example

let _s = just("hello").subscribe(PrintObserver::new("just"));

Output:

just - next: "hello"
just - completed
just - unsubscribed