Struct Tokio 

pub struct Tokio;

Runtime implementation, which works with Tokio’s multi thread runtime.

Trait Implementations

impl Clone for Tokio

fn clone(&self) -> Tokio

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Tokio

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Runtime for Tokio

Available on crate features experimental_async_runtime and rt-tokio only.

fn spawn<F>(&self, future: F)

where F: Future<Output = ()> + Send + 'static,

Spawn a new task or thread, which executes the given future.

fn delay(&self, duration: Duration) -> impl Future<Output = ()> + Send + 'static

Return a future that resolves after the specified Duration.

impl RuntimeChannel for Tokio

Available on crate features experimental_async_runtime and rt-tokio only.

type Receiver<T: Debug + Send> = ReceiverStream<T>

A future stream to receive batch messages from channels.

type Sender<T: Debug + Send> = Sender<T>

A batch messages sender that can be sent across threads safely.

fn batch_message_channel<T: Debug + Send>( &self, capacity: usize, ) -> (Self::Sender<T>, Self::Receiver<T>)

Return the sender and receiver used to send batch messages.