Struct TokioCurrentThread

pub struct TokioCurrentThread;

Available on crate feature rt-tokio-current-thread only.

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

Trait Implementations

impl Clone for TokioCurrentThread

fn clone(&self) -> TokioCurrentThread

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TokioCurrentThread

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

Formats the value using the given formatter.

impl Runtime for TokioCurrentThread

type Interval = IntervalStream

A future stream, which returns items in a previously specified interval. The item type is not important.

type Delay = Sleep

A future, which resolves after a previously specified amount of time. The output type is not important.

fn interval(&self, duration: Duration) -> Self::Interval

Create a Stream, which returns a new item every Duration.

fn spawn(&self, future: BoxFuture<'static, ()>)

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

fn delay(&self, duration: Duration) -> Self::Delay

Return a new future, which resolves after the specified Duration.

impl TraceRuntime for TokioCurrentThread

Available on crate feature trace only.

type Receiver = ReceiverStream<BatchMessage>

A future stream to receive the batch messages from channels.

type Sender = Sender<BatchMessage>

A batch messages sender that could be sent across thread safely.

fn batch_message_channel( &self, capacity: usize, ) -> (Self::Sender, Self::Receiver)

Return the sender and receiver used to send batch message between tasks.