Function tikv_util::stream::with_timeout

pub async fn with_timeout<T, E, Fut>(
    timeout_duration: Duration, 
    fut: Fut
) -> Result<T, E> where
    Fut: Future<Output = Result<T, E>> + Unpin,
    E: From<Box<dyn Error + Send + Sync>>,