another_rxrust/observables/
empty.rs

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