kernel 1.1.0

Abstract Reactive Streams
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45


#![allow(unused_must_use)]
#![allow(unused_mut)]
#![allow(unused_variables)]
#![allow(unused_imports)]

// MIO Compatibility Sample

extern crate kernel;

use kernel::io::*;
use kernel::io::poll::*;
use kernel::io::ready::*;
use kernel::io::token::*;
use kernel::io::options::*;
use kernel::io::tcp::*;

const SERVER: Token = Token(0);
const CLIENT: Token = Token(1);


fn main() {

    let addr = "127.0.0.1:13265".parse().unwrap();
    let server = TcpListener::bind(&addr).unwrap();
    let sock = TcpStream::connect(&addr).unwrap();
    let mut poll = Poll::new().unwrap();
    let mut events = Events::with_capacity(1024);
    poll.register(&server, SERVER, Ready::readable(), PollOpt::edge()).unwrap();
    poll.register(&sock, CLIENT, Ready::readable(), PollOpt::edge()).unwrap();
    loop {
        poll.poll(&mut events, None).unwrap();
        for event in events.iter() {
            match event.token() {
                SERVER => {
                    let _ = server.accept();
                }
                CLIENT => {
                    return;
                }
                _ => unreachable!(),
            }
        }
    }
}