tab-command 0.5.7

the cli command module for the tab terminal multiplexer
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

use crate::prelude::*;
use crate::{
    env::terminal_size, message::terminal::TerminalInput, state::terminal::TerminalSizeState,
};
use anyhow::Context;
use crossterm::event::Event;
use std::time::Duration;

/// Broadcasts the TerminalSizeState, and sends TerminalSend::Resize events.
pub struct TerminalEventService {
    _update: Lifeline,
}

impl Service for TerminalEventService {
    type Bus = TerminalBus;
    type Lifeline = anyhow::Result<Self>;

    fn spawn(bus: &TerminalBus) -> Self::Lifeline {
        let mut tx = bus.tx::<TerminalSizeState>()?;
        let mut tx_send = bus.tx::<TerminalInput>()?;

        #[allow(unreachable_code)]
        let _update = Self::try_task("run", async move {
            let mut set_size = (0, 0);
            loop {
                let size = terminal_size().expect("get terminal size");
                if size != set_size {
                    set_size = size;

                    tx.send(TerminalSizeState(set_size))
                        .await
                        .context("send TerminalStateSize")?;

                    tx_send
                        .send(TerminalInput::Resize(set_size))
                        .await
                        .context("send TerminalStateSize")?;
                }

                tokio::time::delay_for(Duration::from_millis(200)).await;
            }

            Ok(())
        });

        Ok(Self { _update })
    }
}

fn _block_for_event() -> Option<Event> {
    if crossterm::event::poll(Duration::from_millis(500)).unwrap_or(false) {
        crossterm::event::read().ok()
    } else {
        None
    }
}