dbuff 0.1.0

Double-buffered state with async command chains, streaming, and keyed task pools for ratatui applications
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

use dbuff::*;
use std::time::Duration;

#[derive(Debug, Clone, Default)]
struct AppData {
    items: Vec<i32>,
}

#[tokio::main]
async fn main() {
    let (domain, write_handle) = SharedDomainData::with_coalesce(
        AppData::default(),
        Duration::from_millis(1),
    );
    tokio::spawn(write_handle.run());

    // These all arrive within the coalesce window → single batch
    for i in 0..100 {
        domain.modify(move |data| {
            data.items.push(i);
        });
    }

    tokio::time::sleep(Duration::from_millis(10)).await;

    let guard = domain.read();
    assert_eq!(guard.items.len(), 100);
    println!("items: {:?}", &guard.items[..10]);
}