Trait rocketmq_common::common::thread::TokioRunnable

source · 
pub trait TokioRunnable: Sync + 'static + Send {
    // Required method
    fn run(&mut self) -> impl Future<Output = ()> + Send;
}

Required Methods§

source

fn run(&mut self) -> impl Future<Output = ()> + Send

Object Safety§

This trait is not object safe.

Implementors§