Struct futures::stream::Forward [] [src]

#[must_use = "futures do nothing unless polled"]
pub struct Forward<T: Stream, U> { /* fields omitted */ }

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.

Methods

impl<T, U> Forward<T, U> where
    U: Sink<SinkItem = T::Item>,
    T: Stream,
    T::Error: From<U::SinkError>, 
[src]

[src]

Get a shared reference to the inner sink. If this combinator has already been polled to completion, None will be returned.

[src]

Get a mutable reference to the inner sink. If this combinator has already been polled to completion, None will be returned.

[src]

Get a shared reference to the inner stream. If this combinator has already been polled to completion, None will be returned.

[src]

Get a mutable reference to the inner stream. If this combinator has already been polled to completion, None will be returned.

Trait Implementations

impl<T: Debug + Stream, U: Debug> Debug for Forward<T, U> where
    T::Item: Debug
[src]

[src]

Formats the value using the given formatter.

impl<T, U> Future for Forward<T, U> where
    U: Sink<SinkItem = T::Item>,
    T: Stream,
    T::Error: From<U::SinkError>, 
[src]

The type of value that this future will resolved with if it is successful. Read more

The type of error that this future will resolve with if it fails in a normal fashion. Read more

[src]

Query this future to see if its value has become available, registering interest if it is not. Read more

[src]

Block the current thread until this future is resolved. Read more

[src]

Map this future's result to a different type, returning a new future of the resulting type. Read more

[src]

Map this future's error to a different error, returning a new future. Read more

[src]

Map this future's error to any error implementing From for this future's Error, returning a new future. Read more

[src]

Chain on a computation for when a future finished, passing the result of the future to the provided closure f. Read more

[src]

Execute another future after this one has resolved successfully. Read more

[src]

Execute another future if this one resolves with an error. Read more

[src]

Waits for either one of two futures to complete. Read more

[src]

Waits for either one of two differently-typed futures to complete. Read more

[src]

Joins the result of two futures, waiting for them both to complete. Read more

[src]

Same as join, but with more futures.

[src]

Same as join, but with more futures.

[src]

Same as join, but with more futures.

[src]

Convert this future into a single element stream. Read more

[src]

Flatten the execution of this future when the successful result of this future is itself another future. Read more

[src]

Flatten the execution of this future when the successful result of this future is a stream. Read more

[src]

Fuse a future such that poll will never again be called once it has completed. Read more

[src]

Do something with the item of a future, passing it on. Read more

[src]

Catches unwinding panics while polling the future. Read more

[src]

Create a cloneable handle to this future where all handles will resolve to the same result. Read more