Struct PendingMethodCall 

pub(crate) struct PendingMethodCall {
    stream: Option<MessageStream>,
    serial: NonZeroU32,
}

A method call whose completion can be awaited or joined with other streams.

This is useful for cache population method calls, where joining the [JoinableStream] with an update signal stream can be used to ensure that cache updates are not overwritten by a cache population whose task is scheduled later.

Fields

stream: Option<MessageStream>

serial: NonZeroU32

Trait Implementations

impl Debug for PendingMethodCall

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

Formats the value using the given formatter.

impl Future for PendingMethodCall

type Output = Result<Message, Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl OrderedFuture for PendingMethodCall

type Output = Result<Message, Error>

See OrderedStream::Data.

type Ordering = Sequence

See OrderedStream::Ordering.

fn poll_before( self: Pin<&mut Self>, cx: &mut Context<'_>, before: Option<&Self::Ordering>, ) -> Poll<Option<(Self::Ordering, Self::Output)>>

Attempt to pull out the value of this future, registering the current task for wakeup if needed, and returning None if it is known that the future will not produce a value ordered before the given point.

fn position_hint(&self) -> Option<MaybeBorrowed<'_, Self::Ordering>>

The minimum value of the ordering of the item.