Struct futures_state_stream::MapState [] [src]

pub struct MapState<S, F> { /* fields omitted */ }

A stream which applies a transform to the state of a stream.

Trait Implementations

impl<S, F, B> StateStream for MapState<S, F> where
    S: StateStream,
    F: FnOnce(S::State) -> B, 
[src]

The items being streamed.

The state returned when streaming completes.

The error returned.

Similar to Stream::poll. Read more

Returns this stream as a boxed trait object.

Returns a future which yields the next element of the stream.

Returns a normal Stream which yields the elements of this stream and discards the state.

Returns a stream which applies a transform to items of this stream.

Returns a stream which applies a transform to errors of this stream.

Returns a stream which applies a transform to the state of this stream.

Returns a stream which filters items of this stream by a predicate.

Returns a stream which filters and transforms items of this stream by a predicate.

Returns a stream which transforms results of this stream into a new future.

Returns a stream which transforms items of this stream into a new future.

Returns a stream which transforms the state of this stream into a new future.

Returns a stream which transforms errors of this stream into a new future.

Returns a stream which collects all items of this stream into a Vec, returning it along with the stream's state. Read more

Applies a fold across all elements of this stream and its state.

Returns a stream which skips initial elements matching a predicate.

Returns a future which applies a closure to each item of this stream.

Returns a future which catches panics generated by this stream.

Returns a stream which buffers a fixed number of items of this stream.

Returns a stream which buffers a fixed number of items of this stream, returning them out of order as they become ready. Read more