fahrenheit 4.5.4

toy futures executor (formerly known as toykio)
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

extern crate fahrenheit;
extern crate futures;

use fahrenheit::AsyncTcpListener;
use fahrenheit::AsyncTcpStream;
use futures::io::AsyncReadExt;
use futures::stream::StreamExt;
use std::net::SocketAddr;

async fn listen(addr: &str) {
    let addr: SocketAddr = addr.parse().unwrap();
    let listener = AsyncTcpListener::bind(addr).unwrap();
    let mut incoming = listener.incoming();

    while let Some(stream) = incoming.next().await {
        fahrenheit::spawn(process(stream));
    }
}

async fn process(mut stream: AsyncTcpStream) {
    let mut buf = vec![0; 10];
    let _ = stream.read_exact(&mut buf).await;
    println!("{}", String::from_utf8_lossy(&buf));
}

fn main() {
    fahrenheit::run(listen("127.0.0.1:12345"))
}