Struct runtime_tokio::TokioCurrentThread

pub struct TokioCurrentThread;

The single-threaded Tokio runtime based on tokio-current-thread.

Trait Implementations

impl Debug for TokioCurrentThread

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

Formats the value using the given formatter.

impl Runtime for TokioCurrentThread

fn spawn_boxed(&self, fut: BoxFuture<'static, ()>) -> Result<(), SpawnError>

Spawn a new future.

fn connect_tcp_stream(
    &self,
    addr: &SocketAddr
) -> BoxFuture<'static, Result<Pin<Box<dyn TcpStream>>>>

Create a new TcpStream.

fn bind_tcp_listener(
    &self,
    addr: &SocketAddr
) -> Result<Pin<Box<dyn TcpListener>>>

Create a new TcpListener.

fn bind_udp_socket(&self, addr: &SocketAddr) -> Result<Pin<Box<dyn UdpSocket>>>

Create a new UdpSocket.

fn new_delay(&self, dur: Duration) -> Pin<Box<dyn Delay>>

Create a new Future that wakes up after the given duration

fn new_delay_at(&self, at: Instant) -> Pin<Box<dyn Delay>>

Create a new Future that wakes up at the given time.

fn new_interval(&self, dur: Duration) -> Pin<Box<dyn Interval>>

A stream representing notifications at a fixed interval.