tii 0.0.6

A Low-Latency Web Server.
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

#[cfg(feature = "extras")]
mod inner {
  use std::io::{Read, Write};
  use std::net::{SocketAddr, TcpListener, TcpStream};
  use std::str::FromStr;
  use std::thread::sleep;
  use std::time::Duration;
  use tii::extras;
  use tii::extras::Connector;
  use tii::MimeType;
  use tii::RequestContext;
  use tii::Response;
  use tii::ServerBuilder;
  use tii::TiiResult;

  fn hello(_: &RequestContext) -> TiiResult<Response> {
    Ok(Response::ok("<html><body><h1>Hello</h1></body></html>", MimeType::TextHtml))
  }

  pub(crate) fn work() -> TiiResult<()> {
    let tii_server = ServerBuilder::builder_arc(|builder| {
      builder
        .router(|router| router.route_any("/*", hello))?
        .with_connection_timeout(Some(Duration::from_secs(5)))?
        .ok()
    })?;

    let connector = extras::TcpConnector::start_unpooled("0.0.0.0:28880", tii_server)?;

    let mut stream = TcpStream::connect_timeout(
      &SocketAddr::from_str("127.0.0.1:28880")?,
      Duration::from_secs(30),
    )?;
    stream.set_write_timeout(Some(Duration::from_secs(5)))?;
    stream.write_all("GET / HTTP/1.1\r\n\r\n".as_bytes())?;
    stream.flush()?;
    stream.set_read_timeout(Some(Duration::from_secs(5)))?;
    let mut response = Vec::new();
    stream.read_to_end(&mut response)?;
    assert_eq!(std::str::from_utf8(response.as_slice())?, "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\nContent-Length: 40\r\n\r\n<html><body><h1>Hello</h1></body></html>");

    sleep(Duration::from_secs(5));
    println!("Calling shutdown...");
    assert!(connector.shutdown_and_join(None));
    println!("Shutdown complete");
    drop(connector);

    // With the connector having finished shutdown()
    let _listen = TcpListener::bind("0.0.0.0:28880")?;

    println!("Done");
    Ok(())
  }
}

#[cfg(feature = "extras")]
#[test]
fn run() {
  inner::work().expect("ERROR");
}