udp 10.2.2

A lightweight and efficient Rust library for building UDP servers with request-response handling.
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

use super::*;

/// Provides a default implementation for `ServerControlHook`.
impl Default for ServerControlHook {
    /// Creates a default `ServerControlHook` with no-op hooks.
    ///
    /// # Returns
    ///
    /// - `Self` - A new instance with default no-op hooks.
    #[inline(always)]
    fn default() -> Self {
        Self {
            wait_hook: Arc::new(|| Box::pin(async {})),
            shutdown_hook: Arc::new(|| Box::pin(async {})),
        }
    }
}

/// Implementation of methods for `ServerControlHook`.
impl ServerControlHook {
    /// Waits for the server to finish.
    pub async fn wait(&self) {
        (self.get_wait_hook())().await;
    }

    /// Shuts down the server.
    pub async fn shutdown(&self) {
        (self.get_shutdown_hook())().await;
    }
}

/// Implementation of methods for `HandlerState`.
impl HandlerState {
    /// Creates a new HandlerState instance.
    ///
    /// # Arguments
    ///
    /// - `ArcRwLockUdpSocket` - The network socket.
    ///
    /// # Returns
    ///
    /// - `Self` - The newly created handler state.
    #[inline(always)]
    pub(crate) fn new(socket: ArcRwLockUdpSocket) -> Self {
        Self { socket }
    }
}

/// Implementation of `ServerHook` for `DefaultServerHook`.
impl ServerHook for DefaultServerHook {
    /// Creates a new instance of `DefaultServerHook`.
    ///
    /// # Arguments
    ///
    /// - `&Context` - The request context (unused).
    ///
    /// # Returns
    ///
    /// A future that resolves to a new `DefaultServerHook` instance.
    async fn new(_ctx: &Context) -> Self {
        Self
    }

    /// Executes the default hook's processing logic (no-op).
    ///
    /// # Arguments
    ///
    /// - `&Context` - The request context (unused).
    async fn handle(self, _ctx: &Context) {}
}