Skip to main content

write_loop

Function write_loop 

Source
pub async fn write_loop(
    storage: Arc<dyn StoragePlugin>,
    registry: Arc<PvRegistry>,
    rx: Receiver<PvSample>,
    shutdown: Receiver<bool>,
    flush_period: Duration,
)
Expand description

Background writer task — drains samples and writes to storage.

Thin wrapper that fills WriteLoopConfig from Default and the caller-supplied flush_period. Production callers use this form; the test suite uses write_loop_with_config directly to dial timeouts down.