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

use tokio::sync::watch::Sender;

use super::{client_status::ClientStatus, error::SharedStateError};

#[derive(Debug)]
pub(crate) struct ClientHalf {
    handle_notifier: Sender<ClientStatus>,
}

impl ClientHalf {
    pub(super) fn new(handle_notifier: Sender<ClientStatus>) -> Self {
        Self { handle_notifier }
    }

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

        Ok(())
    }
}