Skip to main content

await_control_rpc_or_lifecycle_close

query::dist_plan::remote_dyn_filter_registry

Function await_control_rpc_or_lifecycle_close 

Source 
async fn await_control_rpc_or_lifecycle_close<T>(
    lifecycle_rx: &mut Receiver<()>,
    operation: String,
    rpc: impl Future<Output = T>,
    control_rpc_timeout: Duration,
) -> ControlRpcResult<T>