tightbeam-rs 0.8.0

A secure, high-performance messaging protocol library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

/// Relay - A simple MPSC relay for any Beamable type
#[macro_export]
macro_rules! relay {
	($beamable:expr, $tx:expr) => {{
		// Build a simple V0 wrapper with id=0, order=0
		let __frame = match $crate::utils::compose($crate::Version::V0)
			.with_id(b"\0")
			.with_order(0u64)
			.with_message($beamable)
			.build()
		{
			Ok(f) => f,
			Err(_) => return None,
		};

		// Send over any std::sync::mpsc::Sender<Frame>-like channel
		match $tx.send(__frame) {
			Ok(_) => Some(()),
			Err(_) => None,
		}
	}};
}