chunk-flush 0.1.0

Flush-on-newline buffer for streaming LLM output. Holds bytes until a newline or N millis pass, then yields a complete chunk. Zero deps.
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

use chunk_flush::Flusher;

#[test]
fn flushes_on_newline() {
    let mut f = Flusher::new(500);
    assert_eq!(f.push("hello"), None);
    assert_eq!(f.push(" world\n").as_deref(), Some("hello world\n"));
}

#[test]
fn flushes_at_cap_without_newline() {
    let mut f = Flusher::new(3);
    assert_eq!(f.push("abc"), None);
    assert_eq!(f.push("d").as_deref(), Some("abcd"));
}

#[test]
fn multi_line_yields_all_complete() {
    let mut f = Flusher::new(1000);
    let r = f.push("one\ntwo\nthree");
    assert_eq!(r.as_deref(), Some("one\ntwo\n"));
    // "three" still buffered
    assert!(!f.is_empty());
}

#[test]
fn force_flush_returns_pending() {
    let mut f = Flusher::new(100);
    f.push("tail");
    assert_eq!(f.flush(), "tail");
    assert!(f.is_empty());
}

#[test]
fn empty_push_returns_none() {
    let mut f = Flusher::new(100);
    assert_eq!(f.push(""), None);
}