Function wasmcloud_control_interface::collect_sub_timeout

source · 
pub async fn collect_sub_timeout<T: DeserializeOwned>(
    sub: Subscriber,
    timeout: Duration,
    reason: &str
) -> Vec<T>
Expand description

Collect results until timeout has elapsed