Struct KqueueReactor 

pub struct KqueueReactor { /* private fields */ }

kqueue reactor for macOS/BSD

Uses BSD’s kqueue interface for event-driven I/O. This is a poll-based reactor (not true async I/O).

Implementations

impl KqueueReactor

pub fn new(max_events: usize) -> Result<Self>

Create a new kqueue reactor

Trait Implementations

impl Reactor for KqueueReactor

fn poll(&mut self, timeout: Option<Duration>) -> Result<Vec<Event>>

Poll for I/O events

fn register(&mut self, fd: RawFd, interest: Interest) -> Result<Token>

Register interest in a file descriptor

fn modify(&mut self, token: Token, interest: Interest) -> Result<()>

Modify interest for a registered file descriptor

fn deregister(&mut self, token: Token) -> Result<()>

Deregister a file descriptor

fn supports_async_io(&self) -> bool

Check if this reactor supports true async I/O (io_uring/IOCP)

fn name(&self) -> &'static str

Get the reactor type name for debugging

fn submit_read( &mut self, _token: Token, _buf: &mut [u8], ) -> Result<Option<Completion>>

Submit an async read operation (for io_uring/IOCP)

fn submit_write( &mut self, _token: Token, _buf: &[u8], ) -> Result<Option<Completion>>

Submit an async write operation (for io_uring/IOCP)