A RetroSearch Logo

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Search Query:

Showing content from https://docs.rs/rdkafka/*/rdkafka/util/struct.TokioRuntime.html below:

TokioRuntime in rdkafka::util - Rust

rdkafka

::

util Struct TokioRuntimeSource 
pub struct TokioRuntime;

Available on crate feature tokio only.

 Expand description

An AsyncRuntime implementation backed by Tokio.

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

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.

Auto Trait Implementations§ § impl Freeze for TokioRuntime § impl RefUnwindSafe for TokioRuntime § impl Send for TokioRuntime § impl Sync for TokioRuntime § impl Unpin for TokioRuntime § impl UnwindSafe for TokioRuntime Blanket Implementations§ Source§ impl<T> Any for T

where T: 'static + ?

Sized

,

Source§ fn type_id(&self) -> TypeId

Gets the

TypeId

of

self

.

Read more Source§ impl<T> Borrow<T> for T

where T: ?

Sized

,

Source§ fn borrow(&self) -> &T

Immutably borrows from an owned value.

Read more Source§ impl<T> BorrowMut<T> for T

where T: ?

Sized

,

Source§ fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value.

Read more Source§ impl<T> From<T> for T Source§ fn from(t: T) -> T

Returns the argument unchanged.

Source§ impl<T> Instrument for T Source§ fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided

Span

, returning an

Instrumented

wrapper.

Read more Source§ fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the

current Span

, returning an

Instrumented

wrapper.

Read more Source§ impl<T, U> Into<U> for T

where U:

From

<T>,

Source§ fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§ impl<T, U> TryFrom<U> for T

where U:

Into

<T>,

Source§ type Error = Infallible

The type returned in the event of a conversion error.

Source§ fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

Source§ impl<T, U> TryInto<U> for T

where U:

TryFrom

<T>,

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

The type returned in the event of a conversion error.

Source§ fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

Source§ impl<T> WithSubscriber for T Source§ fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>

where S:

Into

<

Dispatch

>,

Attaches the provided

Subscriber

to this type, returning a

WithDispatch

wrapper.

Read more Source§ fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current

default Subscriber

to this type, returning a

WithDispatch

wrapper.

Read more

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4