echosrv 0.3.0

A high-performance set of async echo server library built with Tokio for testing and development environments
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
38
39

use crate::EchoError;
use crate::datagram::{DatagramConfig, DatagramProtocol};
use async_trait::async_trait;
use std::net::SocketAddr;
use tokio::net::UdpSocket;

/// UDP protocol implementation
pub struct UdpProtocol;

#[async_trait]
impl DatagramProtocol for UdpProtocol {
    type Error = EchoError;
    type Socket = UdpSocket;

    async fn bind(config: &DatagramConfig) -> std::result::Result<UdpSocket, EchoError> {
        UdpSocket::bind(config.bind_addr)
            .await
            .map_err(|e| EchoError::Config(format!("Failed to bind UDP socket: {e}")))
    }

    async fn recv_from(
        socket: &UdpSocket,
        buffer: &mut [u8],
    ) -> std::result::Result<(usize, SocketAddr), EchoError> {
        socket.recv_from(buffer).await.map_err(EchoError::Udp)
    }

    async fn send_to(
        socket: &UdpSocket,
        data: &[u8],
        addr: SocketAddr,
    ) -> std::result::Result<usize, EchoError> {
        socket.send_to(data, addr).await.map_err(EchoError::Udp)
    }

    fn map_io_error(err: std::io::Error) -> EchoError {
        EchoError::Udp(err)
    }
}