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

use std::net::SocketAddr;

use tokio::sync::oneshot;

use crate::Result;

pub(crate) enum StreamCommand<W> {
    Write(W),
    Flush(oneshot::Sender<Result<()>>),
    WriteAndFlush(W, oneshot::Sender<Result<()>>),
    Close,
}

pub(crate) enum DatagramCommand<W> {
    WriteTo(SocketAddr, W),
    Flush(oneshot::Sender<Result<()>>),
    WriteToAndFlush(SocketAddr, W, oneshot::Sender<Result<()>>),
    Close,
}