Enum mfio_rt::native::NativeRtInstance

pub enum NativeRtInstance {
    IoUring(Runtime),
    Mio(Runtime),
    Default(Runtime),
}

Available on crate feature native only.

Variants

IoUring(Runtime)

Available on non-miri and Linux and crate feature io-uring only.

Mio(Runtime)

Available on non-miri and Unix and crate feature mio only.

Default(Runtime)

Implementations

impl NativeRtInstance

pub fn register_stream(&self, stream: TcpStream) -> NativeTcpStream

Registers a non-seekable I/O stream

TODO: this perhaps should be private. We can’t expose register_file publicly, because on iocp, files need to be opened with appropriate (unchangeable!) flags. Perhaps we should mirror this with streams.

pub fn cancel_all_ops(&self)

Trait Implementations

impl Debug for NativeRtInstance

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

Formats the value using the given formatter.

impl From<NativeRtInstance> for NativeRt

fn from(instance: NativeRtInstance) -> Self

Converts to this type from the input type.

impl IoBackend for NativeRtInstance

type Backend = dyn Future<Output = ()> + Send

fn polling_handle(&self) -> Option<PollingHandle<'_>>

Gets handle to the backing event system.

fn get_backend(&self) -> BackendHandle<'_, Self::Backend>

Acquires exclusive handle to IO backend.

impl Tcp for NativeRtInstance

type StreamHandle = NativeTcpStream

Available on crate feature std only.

type ListenerHandle = NativeTcpListener

Available on crate feature std only.

type ConnectFuture<'a, A: ToSocketAddrs + Send + 'a> = NativeTcpConnectFuture<'a, A>

Available on crate feature std only.

type BindFuture<'a, A: ToSocketAddrs + Send + 'a> = Ready<Result<NativeTcpListener, Error>>

Available on crate feature std only.

fn connect<'a, A: ToSocketAddrs + Send + 'a>( &'a self, addrs: A ) -> Self::ConnectFuture<'a, A>

Available on crate feature std only.

fn bind<'a, A: ToSocketAddrs + Send + 'a>( &'a self, addrs: A ) -> Self::BindFuture<'a, A>

Available on crate feature std only.