pub fn of_fn<F, Item>(f: F) -> CallableObservable<F> where F: FnOnce() -> Item,
Creates an observable that emits the return value of a callable.
Never emits an error.
f
use rxrust::prelude::*; observable::of_fn(|| {1234}) .subscribe(|v| {println!("{},", v)});