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.