spawn_instrumented

xmtp_common::stream_handles

Function spawn_instrumented 

Source 
pub fn spawn_instrumented<F>(
    ready: Option<Receiver<()>>,
    future: F,
) -> impl StreamHandle<StreamOutput = F::Output>
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,