Skip to main content

spawn_affected_rows_trailing_metrics_task

client::database

Function spawn_affected_rows_trailing_metrics_task 

Source 
fn spawn_affected_rows_trailing_metrics_task<S>(
    terminal_metrics: &OutputMetrics,
    reader: FlightMessageReader<S>,
)
where
    S: Stream<Item = Result<FlightMessage>> + Send + Unpin + 'static,