rs-netty 1.0.0

A Tokio-native typed TCP/UDP pipeline framework inspired by Netty.
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

use rs_netty::{
    codec::{HttpCodec, HttpRequest, HttpResponse},
    pipeline, Context, Handler, Result, TcpServer,
};

#[tokio::main]
async fn main() -> Result<()> {
    TcpServer::bind("127.0.0.1:9005")
        .pipeline(|| {
            pipeline()
                .codec(HttpCodec::server().allow_chunked(true))
                .handler(HttpHello)
        })
        .run()
        .await
}

struct HttpHello;

impl Handler<HttpRequest> for HttpHello {
    type Write = HttpResponse;

    async fn read(&mut self, ctx: &mut Context<Self::Write>, request: HttpRequest) -> Result<()> {
        let body = format!(
            "hello from rs-netty http\nmethod={}\ntarget={}\nbody_len={}\n",
            request.method(),
            request.target(),
            request.body().len()
        );

        ctx.write_and_flush(
            HttpResponse::new(200)
                .header("Content-Type", "text/plain; charset=utf-8")
                .body(body),
        )
        .await
    }
}