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
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use rs_netty::{
    codec::{WebSocketCodec, WebSocketInbound, WebSocketOutbound},
    pipeline, Context, Handler, Result, TcpServer,
};

#[tokio::main]
async fn main() -> Result<()> {
    TcpServer::bind("127.0.0.1:9006")
        .pipeline(|| {
            pipeline()
                .codec(WebSocketCodec::server())
                .handler(WebSocketEcho)
        })
        .run()
        .await
}

struct WebSocketEcho;

impl Handler<WebSocketInbound> for WebSocketEcho {
    type Write = WebSocketOutbound;

    async fn read(&mut self, ctx: &mut Context<Self::Write>, msg: WebSocketInbound) -> Result<()> {
        let response = match msg {
            WebSocketInbound::Handshake(handshake) => {
                WebSocketOutbound::from(handshake.accept_response())
            }
            WebSocketInbound::Text(text) => WebSocketOutbound::Text(format!("echo: {text}")),
            WebSocketInbound::Binary(bytes) => WebSocketOutbound::Binary(bytes),
            WebSocketInbound::Ping(bytes) => WebSocketOutbound::Pong(bytes),
            WebSocketInbound::Pong(bytes) => WebSocketOutbound::Pong(bytes),
            WebSocketInbound::Close(close) => WebSocketOutbound::Close(close),
        };

        ctx.write_and_flush(response).await
    }
}