intercomm 0.1.1

Asynchronous inter-component communication library
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

//! Broadcast notifications
//!
//! Notifications with support multiple subscribers

use crate::common::StaticTypeMap;
use tokio::sync::broadcast::Sender;

mod subscription;

#[cfg(test)]
mod test;

pub use subscription::*;

static CHANNELS: StaticTypeMap = StaticTypeMap::new();

/// A multi-notifier, multi-subscriber notification
pub trait Broadcast: Sized + 'static {
    /// The number of notifications
    /// that can be sent without waiting for the receiver
    ///
    /// It must be at least 1
    const BUFFER_SIZE: usize;

    /// Notification name in debug messages
    const DEBUG_NAME: &'static str;

    /// Payload data type that will be sended with this notification
    type Payload: Clone + Send;
}

/// Sends a payload to the [Subscription](crate::broadcast::Subscription)
pub async fn notify<B: Broadcast>(payload: B::Payload) {
    let id = id!(B);
    let channels = CHANNELS.read().await;
    let sender = match channels.get(&id) {
        Some(sender) => sender,
        None => return,
    };
    let sender: &Sender<_> = unsafe { sender.get_ref() };
    let _ = sender.send(payload);
}