observer_print

Print all observed signals to stdout for quick debugging.

See Also

• FnObserver / DynFnObserver - Provide custom callbacks to handle signals.
• NoopObserver - Ignore all signals (panics on errors in debug).

Example

cargo run -p rx_core --example observer_print_example

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

Output:

hello - next: 1
hello - completed
hello - unsubscribed