rs-netty 1.1.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

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

fn main() {
    let _server = TcpServer::bind("127.0.0.1:0").pipeline(|| {
        pipeline()
            .codec(HttpCodec::server())
            .handler(HttpHandler)
    });
}

struct HttpHandler;

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

    async fn read(&mut self, ctx: &mut Context<Self::Write>, request: HttpRequest) -> Result<()> {
        ctx.write(HttpResponse::new(200).body(format!("path={}", request.target())))
            .await
    }
}