ruyi 0.1.6

An event-driven framework for non-blocking, asynchronous I/O in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

extern crate ruyi;
extern crate futures;

use std::thread;
use std::time::Duration;

use futures::Stream;

use ruyi::channel::spsc;
use ruyi::stream::IntoStream;
use ruyi::reactor;

#[test]
fn spsc() {
    let (tx, rx) = spsc::sync_channel::<usize>(1).unwrap();
    let handle = thread::spawn(move || {
        let task = rx.into_stream().for_each(|_| Ok(()));
        reactor::run(task).unwrap();
    });
    tx.send(1).unwrap();
    thread::sleep(Duration::from_millis(100));
    drop(tx);
    handle.join().unwrap();
}