Trait kvarn_quinn::Runtime

pub trait Runtime: Send + Sync + Debug + 'static {
    // Required methods
    fn new_timer(&self, i: Instant) -> Pin<Box<dyn AsyncTimer>>;
    fn spawn(&self, future: Pin<Box<dyn Future<Output = ()> + Send>>);
    fn wrap_udp_socket(&self, t: UdpSocket) -> Result<Arc<dyn AsyncUdpSocket>>;
}

Abstracts I/O and timer operations for runtime independence

Required Methods

fn new_timer(&self, i: Instant) -> Pin<Box<dyn AsyncTimer>>

Construct a timer that will expire at i

fn spawn(&self, future: Pin<Box<dyn Future<Output = ()> + Send>>)

Drive future to completion in the background

fn wrap_udp_socket(&self, t: UdpSocket) -> Result<Arc<dyn AsyncUdpSocket>>

Convert t into the socket type used by this runtime

Implementors

impl Runtime for AsyncStdRuntime

impl Runtime for SmolRuntime

impl Runtime for TokioRuntime