Struct TokioRuntimeProvider

pub struct TokioRuntimeProvider(/* private fields */);

The Tokio Runtime for async execution

Implementations

impl TokioRuntimeProvider

pub fn new() -> TokioRuntimeProvider

Create a Tokio runtime

Trait Implementations

impl Clone for TokioRuntimeProvider

fn clone(&self) -> TokioRuntimeProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TokioRuntimeProvider

fn default() -> TokioRuntimeProvider

Returns the “default value” for a type.

impl RuntimeProvider for TokioRuntimeProvider

type Handle = TokioHandle

Handle to the executor;

type Timer = TokioTime

Timer

type Udp = UdpSocket

UdpSocket

type Tcp = AsyncIoTokioAsStd<TcpStream>

TcpStream

fn create_handle(&self) -> <TokioRuntimeProvider as RuntimeProvider>::Handle

Create a runtime handle

fn connect_tcp( &self, server_addr: SocketAddr, bind_addr: Option<SocketAddr>, wait_for: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<<TokioRuntimeProvider as RuntimeProvider>::Tcp, Error>> + Send>>

Create a TCP connection with custom configuration.

fn bind_udp( &self, local_addr: SocketAddr, _server_addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<<TokioRuntimeProvider as RuntimeProvider>::Udp, Error>> + Send>>

Create a UDP socket bound to local_addr. The returned value should not be connected to server_addr. Notice: the future should be ready once returned at best effort. Otherwise UDP DNS may need much more retries.

fn quic_binder(&self) -> Option<&dyn QuicSocketBinder>

Yields an object that knows how to bind a QUIC socket.