another_rxrust/observables/
range.rs

1use crate::prelude::*;
2
3pub fn range<'a>(initial: i64, count: i64) -> Observable<'a, i64> {
4  Observable::create(move |s| {
5    for n in initial..(initial + count) {
6      if !s.is_subscribed() {
7        break;
8      }
9      s.next(n.clone());
10    }
11    s.complete();
12  })
13}
14
15#[cfg(test)]
16mod test {
17  use crate::prelude::*;
18
19  #[test]
20  fn basic() {
21    observables::range(5, 5).subscribe(print_next_fmt!("{}"), print_error!(), print_complete!());
22  }
23}