Struct tokio::prelude::stream::Buffered [−][src]
An adaptor for a stream of futures to execute the futures concurrently, if possible.
This adaptor will buffer up a list of pending futures, and then return their
results in the order that they were pulled out of the original stream. This
is created by the Stream::buffered
method.
Methods
impl<S> Buffered<S> where
S: Stream,
<S as Stream>::Item: IntoFuture,
<<S as Stream>::Item as IntoFuture>::Error == <S as Stream>::Error,
[src]
[−]
impl<S> Buffered<S> where
S: Stream,
<S as Stream>::Item: IntoFuture,
<<S as Stream>::Item as IntoFuture>::Error == <S as Stream>::Error,
ⓘImportant traits for &'a mut Rpub fn get_ref(&self) -> &S
[src]
[−]
pub fn get_ref(&self) -> &S
Acquires a reference to the underlying stream that this combinator is pulling from.
ⓘImportant traits for &'a mut Rpub fn get_mut(&mut self) -> &mut S
[src]
[−]
pub fn get_mut(&mut self) -> &mut S
Acquires a mutable reference to the underlying stream that this combinator is pulling from.
Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this combinator.
pub fn into_inner(self) -> S
[src]
[−]
pub fn into_inner(self) -> S
Consumes this combinator, returning the underlying stream.
Note that this may discard intermediate state of this combinator, so care should be taken to avoid losing resources when this is called.
Trait Implementations
impl<S> Sink for Buffered<S> where
S: Sink + Stream,
<S as Stream>::Item: IntoFuture,
[src]
[+]
impl<S> Sink for Buffered<S> where
S: Sink + Stream,
<S as Stream>::Item: IntoFuture,
impl<S> Stream for Buffered<S> where
S: Stream,
<S as Stream>::Item: IntoFuture,
<<S as Stream>::Item as IntoFuture>::Error == <S as Stream>::Error,
[src]
[+]
impl<S> Stream for Buffered<S> where
S: Stream,
<S as Stream>::Item: IntoFuture,
<<S as Stream>::Item as IntoFuture>::Error == <S as Stream>::Error,
impl<S> Debug for Buffered<S> where
S: Stream + Debug,
<S as Stream>::Item: IntoFuture,
<<S as Stream>::Item as IntoFuture>::Future: Debug,
<<S as Stream>::Item as IntoFuture>::Item: Debug,
<<S as Stream>::Item as IntoFuture>::Error: Debug,
[src]
[+]
impl<S> Debug for Buffered<S> where
S: Stream + Debug,
<S as Stream>::Item: IntoFuture,
<<S as Stream>::Item as IntoFuture>::Future: Debug,
<<S as Stream>::Item as IntoFuture>::Item: Debug,
<<S as Stream>::Item as IntoFuture>::Error: Debug,