reception 0.1.2

A Rust library for creating TCP listeners that spawns clients providing model abstraction layer.
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

use tokio::sync::watch::{error::SendError, Receiver, Sender};

use crate::connection::ConnectionConfig;

use super::{
    connection_status::ConnectionStatus, error::SharedStateError, handle_status::HandleStatus,
};

#[derive(Debug)]
pub(crate) struct HandleHalf {
    config: ConnectionConfig,
    connection_notifier: Sender<HandleStatus>,
    handle_receiver: Receiver<ConnectionStatus>,
}

impl HandleHalf {
    pub(super) fn new(
        config: ConnectionConfig,
        connection_notifier: Sender<HandleStatus>,
        handle_receiver: Receiver<ConnectionStatus>,
    ) -> Self {
        Self {
            config,
            connection_notifier,
            handle_receiver,
        }
    }

    pub(crate) fn notify(&self, status: HandleStatus) -> Result<(), SharedStateError> {
        self.connection_notifier
            .send(status)
            .map_err(|SendError(status)| SharedStateError::HandleFailedToShareUpdate(status))?;

        Ok(())
    }

    pub(crate) fn receiver(&self) -> Receiver<ConnectionStatus> {
        self.handle_receiver.clone()
    }

    pub(crate) fn config(&self) -> &ConnectionConfig {
        &self.config
    }
}