Enum RocketMQRuntime

pub enum RocketMQRuntime {
    Multi(Runtime),
}

Variants

Multi(Runtime)

Implementations

impl RocketMQRuntime

pub fn new_multi(threads: usize, name: &str) -> Self

impl RocketMQRuntime

pub fn get_handle(&self) -> &Handle

pub fn get_runtime(&self) -> &Runtime

pub fn shutdown(self)

pub fn shutdown_timeout(self, timeout: Duration)

pub fn schedule_at_fixed_rate<F>( &self, task: F, initial_delay: Option<Duration>, period: Duration, )

where F: Fn() + Send + 'static,

pub fn schedule_at_fixed_rate_mut<F>( &self, task: F, initial_delay: Option<Duration>, period: Duration, )

where F: FnMut() + Send + 'static,