Crate ntex_io 

Asynchronous I/O abstractions for the ntex ecosystem.

Io wraps an underlying IoStream and coordinates buffered reads, writes, backpressure, timeouts, and shutdown. Protocol transforms can be composed through Filter layers, while Framed combines an I/O stream with an ntex-codec encoder and decoder.

Use IoConfig to configure buffer thresholds and connection timeouts.

Re-exports

pub use self::cfg::IoConfig;

Modules

cfg

testing

utilities and helpers for testing

types

Query related types

Macros

forward_query

forward_ready

Implements Filter::poll_read_ready and Filter::poll_write_ready by forwarding readiness checks to a field.

forward_shutdown

Structs

Base

Default Io filter

FilterBuf

FilterCtx

Framed

A codec-driven interface to an underlying I/O stream.

Id

Io

Buffered, filterable interface to an underlying I/O stream.

IoBoxed

Boxed Io object with erased filter type

IoContext

Context for io read task

IoRef

Cloneable reference to an Io connection’s shared state.

Layer

OnDisconnect

The OnDisconnect future resolves when the I/O stream is disconnected.

Sealed

Sealed filter type

TimerHandle

Enums

IoStatusUpdate

I/O status update events.

IoTaskStatus

Current status of the I/O state.

Readiness

Filter readiness state.

RecvError

Errors that can occur while receiving data.

Traits

Filter

FilterLayer

A processing layer that transforms an I/O stream’s read and write buffers.

Handle

Control handle for transport-specific I/O tasks.

IoStream

An underlying transport that can be managed by Io.