Function rxrust::observable::of::of_result

pub fn of_result<Item, Err>(r: Result<Item, Err>) -> ResultObservable<Item, Err>

Creates an observable that emits value or the error from a Result given.

Completes immediately after.

Arguments

• r - A Result argument to take a value, or an error to emits from.

Examples

use rxrust::prelude::*;

observable::of_result(Ok(1234))
  .subscribe(|v| {println!("{},", v)});

use rxrust::prelude::*;

observable::of_result(Err("An error"))
  .subscribe_err(|v: &i32| {}, |e| {println!("Error:  {},", e)});