Trait ntex_io::FilterLayer

pub trait FilterLayer: 'static {
    const BUFFERS: bool = true;

    fn process_read_buf(&self, buf: &mut ReadBuf<'_>) -> Result<usize>;
    fn process_write_buf(&self, buf: &mut WriteBuf<'_>) -> Result<()>;

    fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<ReadStatus> { ... }
    fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<WriteStatus> { ... }
    fn query(&self, id: TypeId) -> Option<Box<dyn Any>> { ... }
    fn shutdown(&self, buf: &mut WriteBuf<'_>) -> Result<Poll<()>> { ... }
}

Provided Associated Constants

const BUFFERS: bool = true

Create buffers for this filter

Required Methods

fn process_read_buf(&self, buf: &mut ReadBuf<'_>) -> Result<usize>

Process read buffer

Inner filter must process buffer before current. Returns number of new bytes.

fn process_write_buf(&self, buf: &mut WriteBuf<'_>) -> Result<()>

Process write buffer

Provided Methods

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

Check readiness for read operations

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

Check readiness for write operations

fn query(&self, id: TypeId) -> Option<Box<dyn Any>>

Query internal filter data

fn shutdown(&self, buf: &mut WriteBuf<'_>) -> Result<Poll<()>>

Gracefully shutdown filter

Implementors