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, BytesMut};

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

/// UDP datagram codec that treats each datagram as one UTF-8 string.
pub struct Utf8DatagramCodec;

impl DatagramDecoder for Utf8DatagramCodec {
    type Item = String;

    fn decode_datagram(&mut self, src: &[u8]) -> Result<Self::Item> {
        String::from_utf8(src.to_vec()).map_err(|err| Error::Decode(err.to_string()))
    }
}

impl DatagramEncoder<String> for Utf8DatagramCodec {
    fn encode_datagram(&mut self, item: String, dst: &mut BytesMut) -> Result<()> {
        dst.reserve(item.len());
        dst.put_slice(item.as_bytes());
        Ok(())
    }
}