Add this to your Cargo.toml:
toml
[dependencies]
rxrust = "0.8.0"
```rust use rxrust:: prelude::*;
let mut numbers = observable::from_iter(0..10); // crate a even stream by filter let even = numbers.clone().filter(|v| v % 2 == 0); // crate an odd stream by filter let odd = numbers.clone().filter(|v| v % 2 != 0);
// merge odd and even stream again even.merge(odd).subscribe(|v| print!("{} ", v, )); // "0 1 2 3 4 5 6 7 8 9" will be printed.
```
In rxrust almost all extensions consume the upstream. So when you try to subscribe a stream twice, the compiler will complain.
rust ignore
# use rxrust::prelude::*;
let o = observable::from_iter(0..10);
o.subscribe(|_| { println!("consume in first")} );
o.subscribe(|_| { println!("consume in second")} );
In this case, we must clone the stream.
rust
# use rxrust::prelude::*;
let o = observable::from_iter(0..10);
o.clone().subscribe(|_| {println!("consume in first")});
o.clone().subscribe(|_| {println!("consume in second")});
```rust use rxrust::prelude::*;
observable::fromiter(0..10) .subscribeon(Schedulers::NewThread) .map(|v| v*2) .toshared() .observeon(Schedulers::NewThread) .to_shared() .subscribe(|v| {println!("{},", v)}); ```
just use observable::from_future to convert a Future to an observable sequence.
```rust use rxrust::prelude::*; use futures::future;
observable::fromfuture(future::ready(1)) .toshared() .subscribe(move |v| println!("subscribed with {}", v));
// because all future in rxrust are execute async, so we wait a second to see // the print, no need to use this line in your code. std::thread::sleep(std::time::Duration::new(1, 0)); ```
A from_future_result function also provided to propagating error from Future.
See missing features to know what rxRust not have for now.
We are looking for contributors! Feel free to open issues for asking questions, suggesting features or other things!
Help and contributions can be any of the following: