istat 0.6.0

A lightweight and batteries-included status_command for i3 and sway
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

use futures::future::join_all;
use tokio::sync::mpsc::error::SendError;
use tokio::sync::mpsc::Sender;

use crate::context::BarEvent;
use crate::error::Result;

#[derive(Debug, Clone)]
pub struct Dispatcher {
    bar_senders: Vec<Option<Sender<BarEvent>>>,
    bar_updater: Sender<()>,
}

impl Dispatcher {
    pub fn new(bar_updater: Sender<()>, capacity: usize) -> Dispatcher {
        Dispatcher {
            bar_senders: vec![None; capacity],
            bar_updater,
        }
    }

    pub fn remove(&mut self, idx: usize) {
        self.bar_senders[idx] = None;
    }

    pub fn set(&mut self, idx: usize, tx: Sender<BarEvent>) {
        self.bar_senders[idx] = Some(tx);
    }

    /// Tell the bar to manually emit an update
    pub async fn manual_bar_update(&self) -> Result<()> {
        self.bar_updater.send(()).await?;
        Ok(())
    }

    /// Send `BarEvent::Signal` to all bar items
    pub async fn signal_all(&self) -> Result<()> {
        Ok(join_all(
            self.bar_senders
                .iter()
                .enumerate()
                .filter_map(|(i, o)| o.as_ref().map(|_| self.send_bar_event(i, BarEvent::Signal))),
        )
        .await
        .into_iter()
        .for_each(|r| {
            if let Err(e) = r {
                log::warn!("{}", e);
            }
        }))
    }

    /// Send the given `BarEvent` to the item at the given index
    pub async fn send_bar_event(&self, idx: usize, ev: BarEvent) -> Result<()> {
        match self.bar_senders.get(idx) {
            Some(Some(tx)) => {
                // if the channel fills up (the bar never reads click events), since this is a bounded channel
                // sending the event would block forever, so just drop the event
                if tx.capacity() == 0 {
                    bail!(
                        "failed to send event to item[{}]: dropping event (channel is full)",
                        idx
                    );
                }

                // send click event to its corresponding bar item
                if let Err(SendError(_)) = tx.send(ev).await {
                    bail!(
                        "failed to send event to item[{}]: dropping event (receiver dropped)",
                        idx
                    );
                }
                Ok(())
            }
            None | Some(None) => bail!("no item found with index: {}", idx),
        }
    }
}