Struct plumbing::Resolver

#[must_use = "Resolvers do nothing unless polled"]pub struct Resolver<St: Stream + Unpin> { /* fields omitted */ }

A Future associated with a request submitted through a Pipeline.

When you successfully submit a request to a Pipeline, it returns a Resolver that can be awaited to retrieve the response for that request. Because responses are retrieved lazily and in order, each Resolver must be awaited in order to receive the responses; later Resolvers will block indefinitely until earlier Resolvers have returned their responses.

If the Stream used by the Pipeline to retrieve responses closes prematurely, all remaining (and new) Resolvers will return None. Ideally this shouldn't happen; the stream should return Some(Err(...)) to each resolver in the event of (for example) an unrecoverable connection failure.

If a Resolver is dropped, the response associated with it will simply be discarded.

Trait Implementations

impl<St: Debug + Stream + Unpin> Debug for Resolver<St>

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

Formats the value using the given formatter.

impl<St: Stream + Unpin> Drop for Resolver<St>

fn drop(&mut self)

Executes the destructor for this type.

impl<St: Stream + Unpin> FusedFuture for Resolver<St>

fn is_terminated(&self) -> bool

Returns true if the underlying future should no longer be polled.

impl<St: Stream + Unpin> Future for Resolver<St>

type Output = Option<St::Item>

The type of value produced on completion.

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

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