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

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

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

#[derive(Debug)]
pub(crate) struct ConnectionHalf {
    handle_notifier: Sender<ConnectionStatus>,
    connection_receiver: Receiver<HandleStatus>,
}

impl ConnectionHalf {
    pub(super) fn new(
        handle_notifier: Sender<ConnectionStatus>,
        connection_receiver: Receiver<HandleStatus>,
    ) -> Self {
        Self {
            handle_notifier,
            connection_receiver,
        }
    }

    pub(crate) fn notify(&self, status: ConnectionStatus) -> Result<(), SharedStateError> {
        self.handle_notifier.send(status).map_err(|_| {
            log::error!(
                "{}:{} Tried to send a new `ConnectionStatus` over the channel and failed. Status: {}.",
                file!(),
                line!(),
                status
            );
            SharedStateError::ConnectionFailedToShareUpdate(status)
        })?;

        Ok(())
    }

    pub(crate) fn receiver_mut(&mut self) -> &mut Receiver<HandleStatus> {
        &mut self.connection_receiver
    }
}