7 releases
0.3.4 | Jun 26, 2024 |
---|---|
0.3.3 | Jun 26, 2024 |
0.3.1 | Oct 15, 2023 |
0.2.4 | Jul 25, 2023 |
0.2.3 | Apr 20, 2023 |
#827 in Rust patterns
63KB
1.5K
SLoC
sod-bus
sod::MutService
implementations to interact with bus::Bus
.
Service Impls
BusBroadcaster
broadcasts to abus::Bus
and blocks until the operation is successful.BusTryBroadcaster
tries to broadcast to abus::Bus
and is able to be retried viasod::RetryService
when the bus buffer is full.BusReceiver
receives from abus::BusReader
, blocking until an element is received.BusTryReceiver
tries to receive from abus::BusReader
and is able to be retried viasod::RetryService
when the bus is empty.
Example
use sod::MutService;
use sod_bus::{BusBroadcaster, BusReceiver};
let mut broadcaster = BusBroadcaster::with_len(1024);
let mut receiver1 = broadcaster.create_receiver();
let mut receiver2 = broadcaster.create_receiver();
broadcaster.process(1).unwrap();
broadcaster.process(2).unwrap();
broadcaster.process(3).unwrap();
assert_eq!(receiver1.process(()).unwrap(), 1);
assert_eq!(receiver1.process(()).unwrap(), 2);
assert_eq!(receiver1.process(()).unwrap(), 3);
assert_eq!(receiver2.process(()).unwrap(), 1);
assert_eq!(receiver2.process(()).unwrap(), 2);
assert_eq!(receiver2.process(()).unwrap(), 3);
Dependencies
~0.8–6MB
~29K SLoC