reactor-rust

reactor-rust is an implementation of the Reactive-Streams in Rust.
It is under active development. Do not use it in a production environment!

Install

Add reactor_rs = 0.0.1 in your Cargo.toml.

Example

Here are some basic example codes:

Mono

```rust extern crate reactor_rs;

use reactorrs::mono; use reactorrs::prelude::*; use std::{thread, time::Duration};

fn main() { mono::just(42) .doonsuccess(|n| { println!( "Answer to the Ultimate Question of Life, The Universe, and Everything: {}", n ); }) .subscribeon(Schedulers::newthread()) .map(|n| n * 2) .subscribe(CoreSubscriber::new( || println!("on complete"), |n| println!("now it should be 84: actual={}!", n), |e| unreachable!(), )); // waiting 1s thread::sleep(Duration::fromsecs(1)); } ```