trotcast 0.5.0

An mpmc broadcast impl
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

use core::sync::atomic::Ordering;

use alloc::{format, string::String, sync::Arc};

use crate::state::State;

/// Debug wrapper for accessing the internal state of the broadcast channel.
pub struct Debug<T> {
    pub shared: Arc<State<T>>,
}

impl<T> Debug<T> {
    pub fn print_state(&self) -> String {
        let mut str = String::new();
        str.push_str(&format!(
            "Tail: {}\nnum readers: {}\n",
            self.shared.tail.load(Ordering::Relaxed),
            self.shared.num_readers.load(Ordering::Relaxed)
        ));
        for (i, ring) in self.shared.ring.iter().enumerate() {
            str.push_str(&format!("Seat({i}): {ring:?}\n"));
            //todo
        }
        str
    }
}