Struct fumio_reactor::reactor::PollEvented

pub struct PollEvented<E> where
    E: Evented,  { /* fields omitted */ }

A wrapper for Read and Write based IO sources.

Methods

impl<E> PollEvented<E> where
    E: Evented, 

pub fn new(io: E, handle: LazyHandle) -> Self

Wrap io and lazily bind to handle on first use.

pub fn try_mut_read<F, T>(
    &mut self,
    context: &mut Context,
    read_op: F
) -> Poll<Result<T>> where
    F: FnMut(&mut E) -> Poll<Result<T>>, 

Try a read operation with mutable IO

If read operation fails make sure to get notified when read readiness is signalled.

pub fn poll_read_ready(&self, context: &mut Context) -> Poll<Result<Ready>>

Clears all pending read events (and returns them)

If no events were pending (and possibly even if there were) the waker in context is registered to be notified when new read events are pending.

pub fn try_mut_write<F, T>(
    &mut self,
    context: &mut Context,
    write_op: F
) -> Poll<Result<T>> where
    F: FnMut(&mut E) -> Poll<Result<T>>, 

Try a write operation with mutable IO

If write operation fails make sure to get notified when write readiness is signalled.

pub fn poll_write_ready(&self, context: &mut Context) -> Poll<Result<Ready>>

Clears all pending write events (and returns them)

If no events were pending (and possibly even if there were) the waker in context is registered to be notified when new write events are pending.

pub fn io_ref(&self) -> &E

Retrieve reference to the contained IO

pub fn io_mut(&mut self) -> &mut E

Retrieve mutable reference to the contained IO

pub fn handle(&self) -> LazyHandle

Retrieve reactor handle this is (going to) be bound to.

Returns an unbound LazyHandle if not registered and not explicitly bound itself.

pub fn into_inner(self) -> E

Detach inner io from reactor and extract it.

Trait Implementations

impl<E: Debug> Debug for PollEvented<E> where
    E: Evented, 

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

Formats the value using the given formatter.

impl<R: Evented + Read + Unpin> AsyncRead for PollEvented<R>

fn poll_read(
    self: Pin<&mut Self>,
    cx: &mut Context,
    buf: &mut [u8]
) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

unsafe fn initializer(&self) -> Initializer

Determines if this AsyncReader can work with buffers of uninitialized memory.

fn poll_read_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context,
    bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<R: Evented + Write + Unpin> AsyncWrite for PollEvented<R>

fn poll_write(
    self: Pin<&mut Self>,
    cx: &mut Context,
    buf: &[u8]
) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<()>>

Attempt to close the object.

fn poll_write_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context,
    bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.