Struct IoContext 

pub struct IoContext(/* private fields */);

Context for io read task

Implementations

impl IoContext

pub fn tag(&self) -> &'static str

Gets the I/O tag.

pub fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<Readiness>

Checks readiness for read operations.

pub fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<Readiness>

Checks readiness for write operations.

pub fn stop(&self, e: Option<Error>)

Stops the I/O stream.

pub fn is_stopped(&self) -> bool

Checks if the I/O stream is stopped.

pub fn get_read_buf(&self) -> BytesMut

Gets the read buffer.

pub fn resize_read_buf(&self, buf: &mut BytesMut)

Resizes the read buffer.

pub fn update_read_status( &self, buf: BytesMut, status: Result<usize>, ) -> IoTaskStatus

Updates the read status.

Returns Ok(Some(buf)) containing the read buffer. Ok(None) indicates that the connection has been disconnected.

pub fn with_write_buf<F, R>(&self, f: F) -> R

where F: FnOnce(&mut BytePages) -> R,

Gets the write buffer.

pub fn update_write_status(&self, status: Result<bool>) -> IoTaskStatus

Updates the write status.

Ok(true) indicates that one or more bytes were successfully written to the I/O stream.

pub fn shutdown(&self, flush: bool, cx: &mut Context<'_>) -> Poll<()>

Waits for the I/O stream to close or begin closing.

pub fn notify(&self)

Notifies read tasks.

Trait Implementations

impl Clone for IoContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IoContext

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

Formats the value using the given formatter.