pub struct Forward<T, U>where
T: Stream,{ /* private fields */ }
Expand description
Future for the Stream::forward
combinator, which sends a stream of values
to a sink and then waits until the sink has fully flushed those values.
Implementations§
source§impl<T, U> Forward<T, U>where
U: Sink<SinkItem = <T as Stream>::Item>,
T: Stream,
<T as Stream>::Error: From<<U as Sink>::SinkError>,
impl<T, U> Forward<T, U>where
U: Sink<SinkItem = <T as Stream>::Item>,
T: Stream,
<T as Stream>::Error: From<<U as Sink>::SinkError>,
sourcepub fn sink_ref(&self) -> Option<&U>
pub fn sink_ref(&self) -> Option<&U>
Get a shared reference to the inner sink. If this combinator has already been polled to completion, None will be returned.
sourcepub fn sink_mut(&mut self) -> Option<&mut U>
pub fn sink_mut(&mut self) -> Option<&mut U>
Get a mutable reference to the inner sink. If this combinator has already been polled to completion, None will be returned.
sourcepub fn stream_ref(&self) -> Option<&T>
pub fn stream_ref(&self) -> Option<&T>
Get a shared reference to the inner stream. If this combinator has already been polled to completion, None will be returned.
sourcepub fn stream_mut(&mut self) -> Option<&mut T>
pub fn stream_mut(&mut self) -> Option<&mut T>
Get a mutable reference to the inner stream. If this combinator has already been polled to completion, None will be returned.
Trait Implementations§
source§impl<T, U> Debug for Forward<T, U>where
T: Debug + Stream,
U: Debug,
<T as Stream>::Item: Debug,
impl<T, U> Debug for Forward<T, U>where
T: Debug + Stream,
U: Debug,
<T as Stream>::Item: Debug,
source§impl<T, U> Future for Forward<T, U>where
U: Sink<SinkItem = <T as Stream>::Item>,
T: Stream,
<T as Stream>::Error: From<<U as Sink>::SinkError>,
impl<T, U> Future for Forward<T, U>where
U: Sink<SinkItem = <T as Stream>::Item>,
T: Stream,
<T as Stream>::Error: From<<U as Sink>::SinkError>,
§type Item = (T, U)
type Item = (T, U)
The type of value that this future will resolved with if it is
successful. Read more
§type Error = <T as Stream>::Error
type Error = <T as Stream>::Error
The type of error that this future will resolve with if it fails in a
normal fashion. Read more
source§fn poll(&mut self) -> Result<Async<(T, U)>, <T as Stream>::Error>
fn poll(&mut self) -> Result<Async<(T, U)>, <T as Stream>::Error>
Query this future to see if its value has become available, registering
interest if it is not. Read more
source§fn wait(self) -> Result<Self::Item, Self::Error>where
Self: Sized,
fn wait(self) -> Result<Self::Item, Self::Error>where
Self: Sized,
Block the current thread until this future is resolved. Read more
source§fn map<F, U>(self, f: F) -> Map<Self, F>where
F: FnOnce(Self::Item) -> U,
Self: Sized,
fn map<F, U>(self, f: F) -> Map<Self, F>where
F: FnOnce(Self::Item) -> U,
Self: Sized,
Map this future’s result to a different type, returning a new future of
the resulting type. Read more
source§fn map_err<F, E>(self, f: F) -> MapErr<Self, F>where
F: FnOnce(Self::Error) -> E,
Self: Sized,
fn map_err<F, E>(self, f: F) -> MapErr<Self, F>where
F: FnOnce(Self::Error) -> E,
Self: Sized,
Map this future’s error to a different error, returning a new future. Read more
source§fn from_err<E>(self) -> FromErr<Self, E>where
E: From<Self::Error>,
Self: Sized,
fn from_err<E>(self) -> FromErr<Self, E>where
E: From<Self::Error>,
Self: Sized,
Map this future’s error to any error implementing
From
for
this future’s Error
, returning a new future. Read moresource§fn then<F, B>(self, f: F) -> Then<Self, B, F>where
F: FnOnce(Result<Self::Item, Self::Error>) -> B,
B: IntoFuture,
Self: Sized,
fn then<F, B>(self, f: F) -> Then<Self, B, F>where
F: FnOnce(Result<Self::Item, Self::Error>) -> B,
B: IntoFuture,
Self: Sized,
Chain on a computation for when a future finished, passing the result of
the future to the provided closure
f
. Read moresource§fn and_then<F, B>(self, f: F) -> AndThen<Self, B, F>where
F: FnOnce(Self::Item) -> B,
B: IntoFuture<Error = Self::Error>,
Self: Sized,
fn and_then<F, B>(self, f: F) -> AndThen<Self, B, F>where
F: FnOnce(Self::Item) -> B,
B: IntoFuture<Error = Self::Error>,
Self: Sized,
Execute another future after this one has resolved successfully. Read more
source§fn or_else<F, B>(self, f: F) -> OrElse<Self, B, F>where
F: FnOnce(Self::Error) -> B,
B: IntoFuture<Item = Self::Item>,
Self: Sized,
fn or_else<F, B>(self, f: F) -> OrElse<Self, B, F>where
F: FnOnce(Self::Error) -> B,
B: IntoFuture<Item = Self::Item>,
Self: Sized,
Execute another future if this one resolves with an error. Read more
source§fn select<B>(self, other: B) -> Select<Self, <B as IntoFuture>::Future>where
B: IntoFuture<Item = Self::Item, Error = Self::Error>,
Self: Sized,
fn select<B>(self, other: B) -> Select<Self, <B as IntoFuture>::Future>where
B: IntoFuture<Item = Self::Item, Error = Self::Error>,
Self: Sized,
Waits for either one of two futures to complete. Read more
source§fn select2<B>(self, other: B) -> Select2<Self, <B as IntoFuture>::Future>where
B: IntoFuture,
Self: Sized,
fn select2<B>(self, other: B) -> Select2<Self, <B as IntoFuture>::Future>where
B: IntoFuture,
Self: Sized,
Waits for either one of two differently-typed futures to complete. Read more
source§fn join<B>(self, other: B) -> Join<Self, <B as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
Self: Sized,
fn join<B>(self, other: B) -> Join<Self, <B as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
Self: Sized,
Joins the result of two futures, waiting for them both to complete. Read more
source§fn join3<B, C>(
self,
b: B,
c: C
) -> Join3<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
C: IntoFuture<Error = Self::Error>,
Self: Sized,
fn join3<B, C>(
self,
b: B,
c: C
) -> Join3<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
C: IntoFuture<Error = Self::Error>,
Self: Sized,
Same as
join
, but with more futures.source§fn join4<B, C, D>(
self,
b: B,
c: C,
d: D
) -> Join4<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
C: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
Self: Sized,
fn join4<B, C, D>(
self,
b: B,
c: C,
d: D
) -> Join4<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
C: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
Self: Sized,
Same as
join
, but with more futures.source§fn join5<B, C, D, E>(
self,
b: B,
c: C,
d: D,
e: E
) -> Join5<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future, <E as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
C: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
E: IntoFuture<Error = Self::Error>,
Self: Sized,
fn join5<B, C, D, E>(
self,
b: B,
c: C,
d: D,
e: E
) -> Join5<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future, <E as IntoFuture>::Future>where
B: IntoFuture<Error = Self::Error>,
C: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
E: IntoFuture<Error = Self::Error>,
Self: Sized,
Same as
join
, but with more futures.source§fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
Convert this future into a single element stream. Read more
source§fn fuse(self) -> Fuse<Self>where
Self: Sized,
fn fuse(self) -> Fuse<Self>where
Self: Sized,
Fuse a future such that
poll
will never again be called once it has
completed. Read moresource§fn inspect<F>(self, f: F) -> Inspect<Self, F>where
F: FnOnce(&Self::Item),
Self: Sized,
fn inspect<F>(self, f: F) -> Inspect<Self, F>where
F: FnOnce(&Self::Item),
Self: Sized,
Do something with the item of a future, passing it on. Read more
Create a cloneable handle to this future where all handles will resolve
to the same result. Read more