Struct Source

pub(crate) struct Source {
    registration: Registration,
    key: usize,
    state: Mutex<[Direction; 2]>,
}

A registered source of I/O events.

Fields

registration: Registration

This source’s registration into the reactor.

key: usize

The key of this source obtained during registration.

state: Mutex<[Direction; 2]>

Inner state with registered wakers.

Implementations

impl Source

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

Polls the I/O source for readability.

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

Polls the I/O source for writability.

fn poll_ready(&self, dir: usize, cx: &mut Context<'_>) -> Poll<Result<()>>

Registers a waker from poll_readable() or poll_writable().

If a different waker is already registered, it gets replaced and woken.

pub(crate) fn readable<T>(handle: &Async<T>) -> Readable<'_, T>

Waits until the I/O source is readable.

pub(crate) fn readable_owned<T>(handle: Arc<Async<T>>) -> ReadableOwned<T>

Waits until the I/O source is readable.

pub(crate) fn writable<T>(handle: &Async<T>) -> Writable<'_, T>

Waits until the I/O source is writable.

pub(crate) fn writable_owned<T>(handle: Arc<Async<T>>) -> WritableOwned<T>

Waits until the I/O source is writable.

fn ready<H: Borrow<Async<T>> + Clone, T>(handle: H, dir: usize) -> Ready<H, T>

Waits until the I/O source is readable or writable.

Trait Implementations

impl Debug for Source

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

Formats the value using the given formatter.