Struct conch_runtime::env::PlatformSpecificAsyncIoEnv

pub struct PlatformSpecificAsyncIoEnv { /* fields omitted */ }

A platform specific environment efficiently using a tokio event loop, if the current platform supports efficient async IO, or a ThreadPoolAsyncIoEnv otherwise.

Methods

impl PlatformSpecificAsyncIoEnv

pub fn new(remote: Remote, fallback_num_threads: Option<usize>) -> Self

Creates a new platform specific environment using a tokio event loop, if such an environment is supported on the current platform.

Otherwise, we will fall back to to a ThreadPoolAsyncIoEnv with the specified number of threads. If None is specified, we'll use one thread per CPU.

Trait Implementations

impl Debug for PlatformSpecificAsyncIoEnv

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

Formats the value using the given formatter.

impl Clone for PlatformSpecificAsyncIoEnv

fn clone(&self) -> PlatformSpecificAsyncIoEnv

Returns a copy of the value.

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

Performs copy-assignment from source.

impl SubEnvironment for PlatformSpecificAsyncIoEnv

fn sub_env(&self) -> Self

Create a new sub-environment, which starts out idential to its parent, but any changes on the new environment will not be reflected on the parent.

impl AsyncIoEnvironment for PlatformSpecificAsyncIoEnv

type Read = PlatformSpecificRead

An async/futures-aware Read adapter around a FileDesc.

type WriteAll = PlatformSpecificWriteAll

An future that represents writing data into a FileDesc.

fn read_async(&mut self, fd: FileDesc) -> Self::Read

Creates a futures-aware adapter to read data from a FileDesc asynchronously.

fn write_all(&mut self, fd: FileDesc, data: Vec<u8>) -> Self::WriteAll

Creates a future for writing data into a FileDesc.

fn write_all_best_effort(&mut self, fd: FileDesc, data: Vec<u8>)

Asynchronously write the contents of data to a FileDesc in the background on a best effort basis (e.g. the implementation can give up due to any (appropriately) unforceen errors like broken pipes).