Struct cros_async::tokio_executor::TokioExecutor

pub struct TokioExecutor {
    runtime: Arc<Runtime>,
    local_set: Arc<OnceLock<SendWrapper<LocalSet>>>,
}

Fields

runtime: Arc<Runtime>

local_set: Arc<OnceLock<SendWrapper<LocalSet>>>

Implementations

impl TokioExecutor

pub fn new() -> AsyncResult<Self>

Trait Implementations

impl AsRawDescriptors for TokioExecutor

fn as_raw_descriptors(&self) -> Vec<RawDescriptor>

Returns the underlying raw descriptors.

impl Clone for TokioExecutor

fn clone(&self) -> TokioExecutor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ExecutorTrait for TokioExecutor

fn async_from<'a, F: IntoAsync + 'a>(&self, f: F) -> AsyncResult<IoSource<F>>

fn run_until<F: Future>(&self, f: F) -> AsyncResult<F::Output>

fn spawn<F>(&self, f: F) -> TaskHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_blocking<F, R>(&self, f: F) -> TaskHandle<R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

fn spawn_local<F>(&self, f: F) -> TaskHandle<F::Output>

where F: Future + 'static, F::Output: 'static,