Struct Executor 

pub struct Executor<'a> {
    async_io: Option<Arc<Executor<'a>>>,
}

A wrapper around the underlying runtime/executor.

This is used to run asynchronous tasks internally and allows integration with various runtimes. See crate::Connection::executor for an example of integration with external runtimes.

Note: You can (and should) completely ignore this type when the tokio backend is in use.

Fields

async_io: Option<Arc<Executor<'a>>>

Implementations

impl Executor<'_>

pub fn is_empty(&self) -> bool

Return true if there are no unfinished tasks.

With the tokio backend in use, this always returns true.

pub async fn tick(&self)

Runs a single task.

With the tokio backend in use, it’s a noop and never returns.

pub(crate) fn new() -> Self

Create a new Executor.

pub(crate) fn needs_internal_driver(&self) -> bool

Whether this executor needs an external driver thread (only the async-io backend does).

pub(crate) async fn run<T>(&self, future: impl Future<Output = T>) -> T

Runs the executor until the given future completes.

With the tokio backend in use, it just awaits on the future.

Trait Implementations

impl<'a> Clone for Executor<'a>

fn clone(&self) -> Executor<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Executor<'a>

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

Formats the value using the given formatter.