bctx-forge 0.1.7

bctx-forge — OS execution substrate, signal capture, BPE tokenizer, SQLite tracker
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

/// Line-by-line output filter with backpressure support.
pub struct OutputStream {
    lines: Vec<String>,
    max_lines: usize,
}

impl OutputStream {
    pub fn new(max_lines: usize) -> Self {
        Self {
            lines: Vec::new(),
            max_lines,
        }
    }

    pub fn feed(&mut self, line: impl Into<String>) -> bool {
        if self.lines.len() < self.max_lines {
            self.lines.push(line.into());
            true
        } else {
            false
        }
    }

    pub fn finish(self) -> Vec<String> {
        self.lines
    }
}