Struct rdkafka::util::TokioRuntime

pub struct TokioRuntime;

This is supported on crate feature tokio only.

An AsyncRuntime implementation backed by Tokio.

This runtime is used by default throughout the crate, unless the tokio feature is disabled.

Trait Implementations

impl AsyncRuntime for TokioRuntime

type Delay = Sleep

The type of the future returned by delay_for.

fn spawn<T>(task: T) where
    T: Future<Output = ()> + Send + 'static, 

Spawns an asynchronous task.

fn delay_for(duration: Duration) -> Self::Delay

Constructs a future that will resolve after duration has elapsed.