terrazzo-terminal 0.2.8

A simple web-based terminal emulator built on Terrazzo.
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

#![cfg(feature = "server")]

use std::collections::VecDeque;
use std::sync::Arc;

use tokio::sync::mpsc;

use super::event::LogEvent;
use crate::logs::state::LogState;

pub struct LogSubscription {
    pub backlog: VecDeque<Arc<LogEvent>>,
    pub receiver: mpsc::UnboundedReceiver<Arc<LogEvent>>,
    subscriber_id: u64,
}

impl LogSubscription {
    pub fn new(
        subscriber_id: u64,
        backlog: VecDeque<Arc<LogEvent>>,
    ) -> (mpsc::UnboundedSender<Arc<LogEvent>>, Self) {
        let (tx, rx) = mpsc::unbounded_channel();
        (
            tx,
            Self {
                backlog,
                receiver: rx,
                subscriber_id,
            },
        )
    }
}

impl Drop for LogSubscription {
    fn drop(&mut self) {
        let _ = LogState::get().unsubscribe(self.subscriber_id);
    }
}