Struct Tokio

pub struct Tokio { /* private fields */ }

Dummy object implementing async common interfaces on top of tokio

Implementations

impl Tokio

pub fn with_handle(self, handle: Handle) -> Self

Bind to the tokio Runtime associated to this handle by default.

pub fn current() -> Self

Bind to the current tokio Runtime by default.

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 Default for Tokio

fn default() -> Tokio

Returns the “default value” for a type.

impl Executor for Tokio

fn block_on<T, F: Future<Output = T>>(&self, f: F) -> T

Block on a future until completion

fn spawn<T: Send + 'static>( &self, f: impl Future<Output = T> + Send + 'static, ) -> impl Task<T>

Spawn a future and return a handle to track its completion.

fn spawn_blocking<F: FnOnce() -> T + Send + 'static, T: Send + 'static>( &self, f: F, ) -> impl Task<T>

Convert a blocking task into a future, spawning it on a decicated thread pool

impl Reactor for Tokio

fn register<H: IO + Send + 'static>( &self, socket: IOHandle<H>, ) -> Result<impl AsyncIOHandle + Send>

Register a synchronous handle, returning an asynchronous one

fn sleep(&self, dur: Duration) -> impl Future<Output = ()>

Sleep for the given duration

fn interval(&self, dur: Duration) -> impl Stream<Item = Instant>

Stream that yields at every given interval

fn tcp_connect<'life0, 'async_trait>( &'life0 self, addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<impl AsyncIOHandle + Send>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a TcpStream by connecting to a remote host

impl RuntimeKit for Tokio