Struct PendingMethodCall 

struct PendingMethodCall {
    serial: NonZeroU32,
    reply_receiver: Receiver<(Sequence, Result<Message>)>,
    pending_method_calls: PendingMethodCalls,
}

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

This is useful for cache population method calls, where joining the call 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

serial: NonZeroU32

reply_receiver: Receiver<(Sequence, Result<Message>)>

pending_method_calls: PendingMethodCalls

Trait Implementations

impl Debug for PendingMethodCall

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

Formats the value using the given formatter.

impl Drop for PendingMethodCall

fn drop(&mut self)

Executes the destructor for this type.

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.