digitalis-server 0.0.0

Base server module for Foxflove
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 digitalis_core::{DigitalisError, DigitalisResult};
use tokio::sync::mpsc::Sender;
use tokio_tungstenite::tungstenite::Message;

pub type ClientId = u32;
pub type MessageSender = Sender<Message>;

#[derive(Debug, Clone)]
pub struct Client {
    id: ClientId,
    sender: MessageSender,
}

impl Client {
    pub const fn new(id: ClientId, sender: MessageSender) -> Self {
        Self { id, sender }
    }

    pub const fn id(&self) -> ClientId {
        self.id
    }

    pub fn nonblocking_send(&self, msg: Message) -> DigitalisResult<()> {
        self.sender
            .try_send(msg)
            .map_err(|_| DigitalisError::ChannelSendError)
    }
}