Function tikv_util::worker::future::poll

fn poll<R, T>(runner: R, rx: UnboundedReceiver<Option<T>>) where
    R: Runnable<T> + Send + 'static,
    T: Display + Send + 'static,