another_rxrust/observables/
just.rs

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