Struct rdkafka::util::TokioRuntime[−][src]

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`[src]

`type Delay = Sleep`

The type of the future returned by delay_for. Read more

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

`fn delay_for(duration: Duration) -> Self::Delay`[src]

Auto Trait Implementations

`impl RefUnwindSafe for TokioRuntime`

`impl Send for TokioRuntime`

`impl Sync for TokioRuntime`

`impl Unpin for TokioRuntime`

`impl UnwindSafe for TokioRuntime`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

`pub fn try_into(self) -> Result<U, >::Error>`[src]

Struct rdkafka::util::TokioRuntime[−][src]

Trait Implementations

`impl AsyncRuntime for TokioRuntime`[src]

`type Delay = Sleep`

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

`fn delay_for(duration: Duration) -> Self::Delay`[src]

Auto Trait Implementations

`impl RefUnwindSafe for TokioRuntime`

`impl Send for TokioRuntime`

`impl Sync for TokioRuntime`

`impl Unpin for TokioRuntime`

`impl UnwindSafe for TokioRuntime`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]

Struct rdkafka::util::TokioRuntime[−][src]

Trait Implementations

impl AsyncRuntime for TokioRuntime[src]

type Delay = Sleep

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

fn delay_for(duration: Duration) -> Self::Delay[src]

Auto Trait Implementations

impl RefUnwindSafe for TokioRuntime

impl Send for TokioRuntime

impl Sync for TokioRuntime

impl Unpin for TokioRuntime

impl UnwindSafe for TokioRuntime

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

`impl AsyncRuntime for TokioRuntime`[src]

`type Delay = Sleep`

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

`fn delay_for(duration: Duration) -> Self::Delay`[src]

`impl RefUnwindSafe for TokioRuntime`

`impl Send for TokioRuntime`

`impl Sync for TokioRuntime`

`impl Unpin for TokioRuntime`

`impl UnwindSafe for TokioRuntime`

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]