Struct UringReaderHandle 

pub struct UringReaderHandle<R> { /* private fields */ }

Handle for the accept loop to register connections with the io_uring reader.

Implementations

impl<R> UringReaderHandle<R>

pub fn register(&mut self, registration: ReaderRegistration<R>)

Register a new connection with the reader thread.

If the reader thread’s channel is dead (thread panicked), logs an error and signals shutdown so the server can restart cleanly.

pub fn shutdown(&self)

Signal the reader thread to shut down and wake it from io_uring_enter.

pub fn join(self)

Join the reader thread. Call after shutdown().