Enum PendingDownstreamReqTask 

pub enum PendingDownstreamReqTask {
    Complete(Result<Option<NextRequest>, Error>),
    Waiting(Receiver<NextRequest>, Instant),
}

This is very similar to a PeekableTask task, but is intentionally set up so that it has no spawned tokio tasks separating us from the oneshot::Sender and detecting when it’s dropped.

The try_recv() method can be used to make sure that we safely recover any pending requests that are sent to us without dropping them.

Variants

Complete(Result<Option<NextRequest>, Error>)

Waiting(Receiver<NextRequest>, Instant)

Implementations

impl PendingDownstreamReqTask

pub fn new( rx: Option<Receiver<NextRequest>>, timeout: Duration, ) -> PendingDownstreamReqTask

pub async fn recv(self) -> Result<Option<DownstreamRequest>, Error>

Receive a downstream request.

This will block until the sender side of the channel is either dropped or sends us a value.

pub async fn await_ready(&mut self)

Drive this task to completion.

If we have passed the deadline for the task, we try to recover any request in the channel. If there is none, then the timed out task will resolve to [Error::NoDownstreamReqsAvailable].

Cancel Safety

Note that this method is used with FutureExt::now_or_never in AsyncItem::is_ready, and should therefore be kept cancel safe.

Trait Implementations

impl Debug for PendingDownstreamReqTask

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

Formats the value using the given formatter.

impl From<PendingDownstreamReqTask> for AsyncItem

fn from(task: PendingDownstreamReqTask) -> Self

Converts to this type from the input type.