Struct ntex_io::IoBoxed

pub struct IoBoxed(_);

Boxed Io object with erased filter type

Methods from Deref<Target = Io<Sealed>>

pub fn set_memory_pool(&self, pool: PoolRef)

Set memory pool

pub fn set_disconnect_timeout(&self, timeout: Millis)

Set io disconnect timeout in millis

pub fn get_ref(&self) -> IoRef

Get instance of IoRef

pub fn filter(&self) -> &F

Get referece to a filter

pub async fn recv<U>(
    &self,
    codec: &U
) -> Result<Option<U::Item>, Either<U::Error, Error>>where
    U: Decoder,

Read incoming io stream and decode codec item.

pub async fn read_ready(&self) -> Result<Option<()>>

Wait until read becomes ready.

pub fn pause(&self)

Pause read task

pub async fn send<U>(
    &self,
    item: U::Item,
    codec: &U
) -> Result<(), Either<U::Error, Error>>where
    U: Encoder,

Encode item, send to a peer

pub async fn flush(&self, full: bool) -> Result<()>

Wake write task and instruct to flush data.

This is async version of .poll_flush() method.

pub async fn shutdown(&self) -> Result<()>

Gracefully shutdown io stream

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

Polls for read readiness.

If the io stream is not currently ready for reading, this method will store a clone of the Waker from the provided Context. When the io stream becomes ready for reading, Waker::wake will be called on the waker.

Return value The function returns:

Poll::Pending if the io stream is not ready for reading. Poll::Ready(Ok(Some(())))) if the io stream is ready for reading. Poll::Ready(Ok(None)) if io stream is disconnected Some(Poll::Ready(Err(e))) if an error is encountered.

pub fn poll_recv<U>(
    &self,
    codec: &U,
    cx: &mut Context<'_>
) -> Poll<Result<U::Item, RecvError<U>>>where
    U: Decoder,

Decode codec item from incoming bytes stream.

Wake read task and request to read more data if data is not enough for decoding. If error get returned this method does not register waker for later wake up action.

pub fn poll_flush(&self, cx: &mut Context<'_>, full: bool) -> Poll<Result<()>>

Wake write task and instruct to flush data.

If full is true then wake up dispatcher when all data is flushed otherwise wake up when size of write buffer is lower than buffer max size.

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

Gracefully shutdown io stream

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

Wait for status updates

Methods from Deref<Target = IoRef>

pub fn memory_pool(&self) -> PoolRef

Get memory pool

pub fn is_closed(&self) -> bool

Check if io stream is closed

pub fn wake(&self)

Wake dispatcher task

pub fn close(&self)

Gracefully close connection

Notify dispatcher and initiate io stream shutdown process.

pub fn force_close(&self)

Force close connection

Dispatcher does not wait for uncompleted responses. Io stream get terminated without any graceful period.

pub fn want_shutdown(&self, err: Option<Error>)

Gracefully shutdown io stream

pub fn query<T: 'static>(&self) -> QueryItem<T>

Query filter specific data

pub fn encode<U>(
    &self,
    item: U::Item,
    codec: &U
) -> Result<(), <U as Encoder>::Error>where
    U: Encoder,

Encode and write item to a buffer and wake up write task

pub fn decode<U>(
    &self,
    codec: &U
) -> Result<Option<<U as Decoder>::Item>, <U as Decoder>::Error>where
    U: Decoder,

Attempts to decode a frame from the read buffer

pub fn write(&self, src: &[u8]) -> Result<()>

Write bytes to a buffer and wake up write task

pub fn with_write_buf<F, R>(&self, f: F) -> Result<R, Error>where
    F: FnOnce(&mut BytesVec) -> R,

Get mut access to write buffer

pub fn with_read_buf<F, R>(&self, f: F) -> Rwhere
    F: FnOnce(&mut BytesVec) -> R,

Get mut access to read buffer

pub fn start_keepalive_timer(&self, timeout: Duration)

Start keep-alive timer

pub fn stop_keepalive_timer(&self)

Stop keep-alive timer

pub fn on_disconnect(&self) -> OnDisconnect

Notify when io stream get disconnected

Trait Implementations

impl Debug for IoBoxed

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

Formats the value using the given formatter.

impl Deref for IoBoxed

type Target = Io<Sealed>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<F: Filter> From<Io<F>> for IoBoxed

fn from(io: Io<F>) -> Self

Converts to this type from the input type.

impl From<Io<Sealed>> for IoBoxed

fn from(io: Io<Sealed>) -> Self

Converts to this type from the input type.