nysa 0.2.2

A bus for passing messages around between independent subsystems of an application
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
43
44
45
46

//! A shared bus for applications that don't need more than one. Comes with some utility methods
//! for simplified usage.

use std::time::Duration;

use lazy_static::lazy_static;

use crate::{iterators::RetrieveAllRef, Bus, Message};

lazy_static! {
   static ref BUS: Bus = Bus::new();
}

/// Pushes a message onto the global bus.
pub fn push<T>(message_data: T)
where
   T: 'static + Send,
{
   BUS.push(message_data);
}

/// Retrieves all messages of the given type from the global bus.
pub fn retrieve_all<T>() -> RetrieveAllRef<'static, T>
where
   T: 'static + Send,
{
   BUS.retrieve_all()
}

/// Blocks execution in the current thread until a message of the provided type arrives on the
/// bus, or the given timeout is reached.
pub fn wait_for_timeout<T>(timeout: Duration) -> Option<Message<'static, T>>
where
   T: 'static + Send,
{
   BUS.wait_for_timeout(timeout)
}

/// Blocks execution in the current thread indefinitely until a message of the given type is
/// available on the global bus.
pub fn wait_for<T>() -> Message<'static, T>
where
   T: 'static + Send,
{
   BUS.wait_for()
}