tk-sendfile 0.4.0

A high-performance file serving library. Serves files in special IO threads. In this version it uses normal file reading, but we will optimize using `sendfile` on supported systems as quick as tokio allows us to do that.
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

extern crate futures;
extern crate futures_cpupool;
extern crate tokio_core;
extern crate tk_sendfile;

use std::net::SocketAddr;
use std::env;

use futures::Future;
use futures::stream::Stream;
use futures_cpupool::CpuPool;
use tokio_core::net::TcpListener;
use tokio_core::reactor::Core;
use tk_sendfile::DiskPool;


fn main() {
    let addr = env::args().nth(1).unwrap_or("127.0.0.1:7777".to_string());
    let addr = addr.parse::<SocketAddr>().unwrap();
    let disk_pool = DiskPool::new(CpuPool::new(40));

    let mut lp = Core::new().unwrap();
    let handle = lp.handle();
    let socket = TcpListener::bind(&addr, &handle).unwrap();
    println!("Listening on: {}", addr);

    let done = socket.incoming().for_each(|(socket, _addr)| {
        handle.spawn(
            disk_pool.send("./examples/send_myself.rs", socket)
            .then(|result| {
                println!("Result {:?}", result);
                Ok(())
            })
        );
        Ok(())
    });

    lp.run(done).unwrap();
}