Struct TokioReactor 

pub struct TokioReactor;

Production reactor wrapping a Tokio current_thread runtime.

Trait Implementations

impl Clone for TokioReactor

fn clone(&self) -> TokioReactor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TokioReactor

fn default() -> TokioReactor

Returns the “default value” for a type.

impl Reactor for TokioReactor

fn clone_box(&self) -> Box<dyn Reactor>

Create a clone of this reactor, boxed.

fn spawn_local( &self, fut: Pin<Box<dyn Future<Output = ()> + Send + 'static>>, ) -> Box<dyn SpawnHandle>

Spawn a task local to the current thread.

fn spawn( &self, fut: Pin<Box<dyn Future<Output = ()> + Send + 'static>>, ) -> Box<dyn SpawnHandle>

Spawn a task that can run on any thread.

fn yield_now(&self) -> Pin<Box<dyn Future<Output = ()> + Send + Sync + 'static>>

Yield execution back to the scheduler.

fn sleep( &self, duration: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + Sync + 'static>>

Sleep for duration under the current time model.

fn now(&self) -> Instant

Return the current instant under the current time model.

fn elapsed_since(&self, start: Instant) -> u64

Measures nanoseconds elapsed since start.

fn create_interval(&self, duration: Duration) -> Box<dyn Interval>

Create a periodic interval that ticks every duration.

fn next_u64(&self) -> u64

Return a random u64 from the reactor’s RNG.

impl Reactor for TokioReactor