[−][src]Struct plumbing::Resolver
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>
[src]
impl<St: Stream + Unpin> Drop for Resolver<St>
[src]
impl<St: Stream + Unpin> FusedFuture for Resolver<St>
[src]
fn is_terminated(&self) -> bool
[src]
impl<St: Stream + Unpin> Future for Resolver<St>
[src]
Auto Trait Implementations
impl<St> !RefUnwindSafe for Resolver<St>
impl<St> Send for Resolver<St> where
St: Send,
St: Send,
impl<St> Sync for Resolver<St> where
St: Send + Sync,
St: Send + Sync,
impl<St> Unpin for Resolver<St>
impl<St> !UnwindSafe for Resolver<St>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> FutureExt for T where
T: Future + ?Sized,
[src]
T: Future + ?Sized,
fn map<U, F>(self, f: F) -> Map<Self, F> where
F: FnOnce(Self::Output) -> U,
[src]
F: FnOnce(Self::Output) -> U,
fn map_into<U>(self) -> MapInto<Self, U> where
Self::Output: Into<U>,
[src]
Self::Output: Into<U>,
fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where
F: FnOnce(Self::Output) -> Fut,
Fut: Future,
[src]
F: FnOnce(Self::Output) -> Fut,
Fut: Future,
fn left_future<B>(self) -> Either<Self, B> where
B: Future<Output = Self::Output>,
[src]
B: Future<Output = Self::Output>,
fn right_future<A>(self) -> Either<A, Self> where
A: Future<Output = Self::Output>,
[src]
A: Future<Output = Self::Output>,
fn into_stream(self) -> IntoStream<Self>
[src]
fn flatten(self) -> Flatten<Self> where
Self::Output: Future,
[src]
Self::Output: Future,
fn flatten_stream(self) -> FlattenStream<Self> where
Self::Output: Stream,
[src]
Self::Output: Stream,
fn fuse(self) -> Fuse<Self>
[src]
fn inspect<F>(self, f: F) -> Inspect<Self, F> where
F: FnOnce(&Self::Output),
[src]
F: FnOnce(&Self::Output),
fn catch_unwind(self) -> CatchUnwind<Self> where
Self: UnwindSafe,
[src]
Self: UnwindSafe,
fn shared(self) -> Shared<Self> where
Self::Output: Clone,
[src]
Self::Output: Clone,
fn remote_handle(self) -> (Remote<Self>, RemoteHandle<Self::Output>)
[src]
fn boxed<'a>(self) -> Pin<Box<dyn Future<Output = Self::Output> + 'a + Send>> where
Self: Send + 'a,
[src]
Self: Send + 'a,
fn boxed_local<'a>(self) -> Pin<Box<dyn Future<Output = Self::Output> + 'a>> where
Self: 'a,
[src]
Self: 'a,
fn unit_error(self) -> UnitError<Self>
[src]
fn never_error(self) -> NeverError<Self>
[src]
fn poll_unpin(&mut self, cx: &mut Context) -> Poll<Self::Output> where
Self: Unpin,
[src]
Self: Unpin,
fn now_or_never(self) -> Option<Self::Output>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,