rdkafka::util

Type Alias DefaultRuntime

Source
pub type DefaultRuntime = TokioRuntime;
Expand description

The default AsyncRuntime used when one is not explicitly specified.

This is defined to be the TokioRuntime when the tokio feature is enabled, or the [NaiveRuntime] if the naive-runtime feature is enabled.

If neither the tokio nor naive-runtime feature is enabled, this is defined to be (), which is not a valid AsyncRuntime and will cause compilation errors if used as one. You will need to explicitly specify a custom async runtime wherever one is required.

Aliased Type§

struct DefaultRuntime;

Trait Implementations

Source§

impl AsyncRuntime for TokioRuntime

Source§

type Delay = Sleep

The type of the future returned by delay_for.
Source§

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

Spawns an asynchronous task. Read more
Source§

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

Constructs a future that will resolve after duration has elapsed.