lib.rs:

一个可嵌入任何 tk-http 应用的 http bin 库

使用 HttpBin 作为工厂和 HttpBin::instantiate 创建 tk_http::server::Dispatcher。

示例

extern crate tokio_core;
extern crate futures;
extern crate tk_http;
extern crate tk_listen;
extern crate httpbin;

use std::time::Duration;
use tokio_core::reactor::Core;
use tokio_core::net::{TcpListener};
use futures::{Stream, Future};
use httpbin::HttpBin;
use tk_http::server::{Config, Proto};
use tk_listen::ListenExt;

let mut lp = Core::new().unwrap();

let addr = "0.0.0.0:8080".parse().unwrap();
let listener = TcpListener::bind(&addr, &lp.handle()).unwrap();
let cfg = Config::new().done();
let bin = HttpBin::new();
let h1 = lp.handle();

let done = listener.incoming()
    .sleep_on_error(Duration::from_millis(100), &h1)
    .map(move |(socket, addr)| {
        Proto::new(socket, &cfg, bin.instantiate(addr), &h1)
        .map_err(|e| { println!("Connection error: {}", e); })
    })
    .listen(1000);

lp.run(done).unwrap();