Struct actix::fut::stream::StreamWrap [−][src]
Trait Implementations
Auto Trait Implementations
impl<S, A> RefUnwindSafe for StreamWrap<S, A> where
A: RefUnwindSafe,
S: RefUnwindSafe,
impl<S, A> Send for StreamWrap<S, A> where
A: Send,
S: Send,
impl<S, A> Sync for StreamWrap<S, A> where
A: Sync,
S: Sync,
impl<S, A> UnwindSafe for StreamWrap<S, A> where
A: UnwindSafe,
S: UnwindSafe,
Blanket Implementations
Maps this stream’s items to a different type, returning a new stream of the resulting type. Read more
Computes from this stream’s items new items of a different type using an asynchronous closure. Read more
Execute an accumulating asynchronous computation over a stream, collecting all the values into one final result. Read more
Take elements from this stream while the provided asynchronous predicate
resolves to true
. Read more
Skip elements on this stream while the provided asynchronous predicate
resolves to true
. Read more
Add timeout to stream. Read more
Transforms a stream into a collection, returning a future representing the result of that computation. Read more
Mutably borrows from an owned value. Read more