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

#1405 in Rust patterns

Download history 55/week @ 2024-07-28 15/week @ 2024-09-15 17/week @ 2024-09-29

288 downloads per month

MIT/Apache

63KB
1.5K SLoC

sod-bus

sod::MutService implementations to interact with bus::Bus.

Service Impls

  • BusBroadcaster broadcasts to a bus::Bus and blocks until the operation is successful.
  • BusTryBroadcaster tries to broadcast to a bus::Bus and is able to be retried via sod::RetryService when the bus buffer is full.
  • BusReceiver receives from a bus::BusReader, blocking until an element is received.
  • BusTryReceiver tries to receive from a bus::BusReader and is able to be retried via sod::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.7–6MB
~28K SLoC