Struct rdkafka::util::NaiveRuntime

pub struct NaiveRuntime;

An AsyncRuntime implementation backed by the executor in the futures crate.

This runtime should not be used when performance is a concern, as it makes heavy use of threads to compenstate for the lack of a timer in the futures executor.

Trait Implementations

impl AsyncRuntime for NaiveRuntime

type Delay = Map<Receiver<()>, fn(_: Result<(), Canceled>)>

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.