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

use bytes::{BufMut, Bytes, BytesMut};

use crate::{
    codec::{DatagramDecoder, DatagramEncoder},
    Result,
};

/// UDP datagram codec that preserves each datagram as raw bytes.
pub struct BytesDatagramCodec;

impl DatagramDecoder for BytesDatagramCodec {
    type Item = Bytes;

    fn decode_datagram(&mut self, src: &[u8]) -> Result<Self::Item> {
        Ok(Bytes::copy_from_slice(src))
    }
}

impl DatagramEncoder<Bytes> for BytesDatagramCodec {
    fn encode_datagram(&mut self, item: Bytes, dst: &mut BytesMut) -> Result<()> {
        dst.reserve(item.len());
        dst.put(item);
        Ok(())
    }
}