Struct TokioRuntimeProvider

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

Available on crate feature tokio-runtime only.

The Tokio Runtime for async execution

Implementations

impl TokioRuntimeProvider

pub fn new() -> Self

Create a Tokio runtime

Trait Implementations

impl Clone for TokioRuntimeProvider

fn clone(&self) -> TokioRuntimeProvider

Returns a copy 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) -> Self::Handle

Create a runtime handle

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

Create a TCP connection with custom configuration.

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

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.