another_rxrust/observables/
error.rs

1use crate::prelude::*;
2
3pub fn error<'a, Item>(err: RxError) -> Observable<'a, Item>
4where
5  Item: Clone + Send + Sync,
6{
7  Observable::<Item>::create(move |s| {
8    s.error(err.clone());
9  })
10}
11
12#[cfg(test)]
13mod test {
14  use crate::prelude::*;
15
16  #[test]
17  fn basic() {
18    observables::error::<String>(RxError::from_error("ERR!")).subscribe(
19      print_next_fmt!("{}"),
20      print_error_as!(&str),
21      print_complete!(),
22    );
23  }
24}