maiko 0.3.1

Lightweight event-driven actor runtime with topic-based pub/sub for Tokio
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

use tokio::sync::broadcast;

use super::Command;
use crate::{Error, Result};

#[repr(transparent)]
#[derive(Clone)]
pub struct CommandSender(broadcast::Sender<Command>);

impl CommandSender {
    pub fn send(&self, cmd: Command) -> Result {
        self.0.send(cmd).map_err(Error::internal)?;
        Ok(())
    }
}

impl From<broadcast::Sender<Command>> for CommandSender {
    fn from(sender: broadcast::Sender<Command>) -> Self {
        CommandSender(sender)
    }
}

impl AsRef<broadcast::Sender<Command>> for CommandSender {
    fn as_ref(&self) -> &broadcast::Sender<Command> {
        &self.0
    }
}