Struct Requesting 

pub struct Requesting { /* private fields */ }

The pollable result of Consumer::request_broadcast.

Awaited via the kio::Pending wrapper; resolves to the broadcast::Consumer immediately when the broadcast was already announced, or once an Dynamic handler serves the request. Resolves to an error if the request is rejected or every handler drops before serving it.

Implementations

impl Requesting

pub fn is_queued(&self) -> bool

Whether the request was handed to a serving route, rather than decided on the spot.

Fixed at request time, so it distinguishes the two ways Error::Unroutable arises: a queued request that fails was killed by its serving route retracting, and the table may already hold a replacement worth retrying against (Consumer::routed_broadcast does), while an unqueued failure means nothing could serve the path at all.

pub fn poll_ok(&self, waiter: &Waiter) -> Poll<Result<Consumer, Error>>

Poll for the requested broadcast without blocking.

Trait Implementations

impl Pollable for Requesting

type Output = Result<Consumer, Error>

The value the computation resolves to.

fn poll(&self, waiter: &Waiter) -> Poll<Self::Output>

Poll for the output, registering waiter with the relevant channels if not yet ready.