Skip to main content

flush_change_stream

objectstore_service::change_stream

Function flush_change_stream 

Source 
pub async fn flush_change_stream(change_stream: &Arc<dyn ChangeStream>)
Expand description

Drains change_stream, bounded by FLUSH_TIMEOUT.

Backends call this from Backend::join so records reported just before shutdown are not silently lost.