Trait microasync_rt::Runtime

pub trait Runtime<'a> {
    fn push_boxed(
        &'a mut self,
        future: Pin<Box<dyn Future<Output = ()> + 'static, Global>>
    );
    fn spawn_boxed(
        &'a mut self,
        future: Pin<Box<dyn Future<Output = ()> + 'static, Global>>
    ) -> SpawnedFuture<'a> ;
    fn sleep<'b>(
        &'a self,
        duration: Duration
    ) -> Pin<Box<dyn Future<Output = ()> + 'b, Global>>;
    fn stop(&mut self);

    fn push(&'a mut self, future: impl Future<Output = ()> + 'static) { ... }
    fn spawn(
        &'a mut self,
        future: impl Future<Output = ()> + 'static
    ) -> SpawnedFuture<'a>  { ... }
    fn sleep_ms<'b>(
        &'a self,
        amount: u64
    ) -> Pin<Box<dyn Future<Output = ()> + 'b, Global>> { ... }
}

Auto-trait with the methods that will actually be called by the users of the runtime.

Required Methods

fn push_boxed(
    &'a mut self,
    future: Pin<Box<dyn Future<Output = ()> + 'static, Global>>
)

Adds a new future to the queue to be completed.

fn spawn_boxed(
    &'a mut self,
    future: Pin<Box<dyn Future<Output = ()> + 'static, Global>>
) -> SpawnedFuture<'a>

Adds a new future to the queue to be completed and returns a future waiting for the added future’s completion.

fn sleep<'b>(
    &'a self,
    duration: Duration
) -> Pin<Box<dyn Future<Output = ()> + 'b, Global>>

Asynchronously sleeps

fn stop(&mut self)

Stops the runtime. This does not exit the process.

Provided Methods

fn push(&'a mut self, future: impl Future<Output = ()> + 'static)

Adds a new future to the queue to be completed.

fn spawn(
    &'a mut self,
    future: impl Future<Output = ()> + 'static
) -> SpawnedFuture<'a>

Adds a new future to the queue to be completed and returns a future waiting for the added future’s completion.

fn sleep_ms<'b>(
    &'a self,
    amount: u64
) -> Pin<Box<dyn Future<Output = ()> + 'b, Global>>

Asynchronously sleeps some amount of milliseconds

Implementors

impl<'a> Runtime<'a> for RuntimeWrapper<'a>

impl<'a, T> Runtime<'a> for Twhere
    T: InternalRuntime,