Struct async_compression::stream::BzDecoder [−][src]
pub struct BzDecoder<S> { /* fields omitted */ }See async-compression::stream docs for migration
stream and bzip2 only.A bzip2 decoder, or decompressor.
This structure implements a Stream interface and will read
compressed data from an underlying stream and emit a stream of uncompressed data.
Implementations
impl<S: Stream<Item = Result<Bytes>>> BzDecoder<S>[src]
impl<S: Stream<Item = Result<Bytes>>> BzDecoder<S>[src]pub fn new(stream: S) -> Self[src]
See async-compression::stream docs for migration
Creates a new decoder which will read compressed data from the given stream and emit an uncompressed stream.
pub fn multiple_members(&mut self, enabled: bool)[src]
See async-compression::stream docs for migration
Configure multi-member/frame decoding, if enabled this will reset the decoder state when reaching the end of a compressed member/frame and expect either the end of the wrapped stream or another compressed member/frame to follow.
pub fn get_ref(&self) -> &S[src]
See async-compression::stream docs for migration
Acquires a reference to the underlying stream that this decoder is wrapping.
pub fn get_mut(&mut self) -> &mut S[src]
See async-compression::stream docs for migration
Acquires a mutable reference to the underlying stream that this decoder is wrapping.
Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this decoder.
pub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut S>[src]
See async-compression::stream docs for migration
Acquires a pinned mutable reference to the underlying stream that this decoder is wrapping.
Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this decoder.
pub fn into_inner(self) -> S[src]
See async-compression::stream docs for migration
Consumes this decoder returning the underlying stream.
Note that this may discard internal state of this decoder, so care should be taken to avoid losing resources when this is called.
Trait Implementations
Auto Trait Implementations
impl<S> RefUnwindSafe for BzDecoder<S> where
S: RefUnwindSafe,
impl<S> RefUnwindSafe for BzDecoder<S> where
S: RefUnwindSafe, impl<S> UnwindSafe for BzDecoder<S> where
S: UnwindSafe,
impl<S> UnwindSafe for BzDecoder<S> where
S: UnwindSafe, Blanket Implementations
impl<St> StreamExt for St where
St: Stream + ?Sized, [src]
impl<St> StreamExt for St where
St: Stream + ?Sized, [src]pub fn next(&mut self) -> Next<'_, Self> where
Self: Unpin, [src]
Self: Unpin,
pub fn try_next<T, E>(&mut self) -> TryNext<'_, Self> where
Self: Stream<Item = Result<T, E>> + Unpin, [src]
Self: Stream<Item = Result<T, E>> + Unpin,
pub fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T, [src]
F: FnMut(Self::Item) -> T,
pub fn merge<U>(self, other: U) -> Merge<Self, U> where
U: Stream<Item = Self::Item>, [src]
U: Stream<Item = Self::Item>,
pub fn filter<F>(self, f: F) -> Filter<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
pub fn filter_map<T, F>(self, f: F) -> FilterMap<Self, F> where
F: FnMut(Self::Item) -> Option<T>, [src]
F: FnMut(Self::Item) -> Option<T>,
pub fn fuse(self) -> Fuse<Self>[src]
pub fn take(self, n: usize) -> Take<Self>[src]
pub fn take_while<F>(self, f: F) -> TakeWhile<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
pub fn skip(self, n: usize) -> Skip<Self>[src]
pub fn skip_while<F>(self, f: F) -> SkipWhile<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
pub fn all<F>(&mut self, f: F) -> AllFuture<'_, Self, F> where
Self: Unpin,
F: FnMut(Self::Item) -> bool, [src]
Self: Unpin,
F: FnMut(Self::Item) -> bool,
pub fn any<F>(&mut self, f: F) -> AnyFuture<'_, Self, F> where
Self: Unpin,
F: FnMut(Self::Item) -> bool, [src]
Self: Unpin,
F: FnMut(Self::Item) -> bool,
pub fn chain<U>(self, other: U) -> Chain<Self, U> where
U: Stream<Item = Self::Item>, [src]
U: Stream<Item = Self::Item>,
pub fn fold<B, F>(self, init: B, f: F) -> FoldFuture<Self, B, F> where
F: FnMut(B, Self::Item) -> B, [src]
F: FnMut(B, Self::Item) -> B,
pub fn collect<T>(self) -> Collect<Self, T> where
T: FromStream<Self::Item>, [src]
T: FromStream<Self::Item>,
impl<St> StreamExt for St where
St: Stream + ?Sized, [src]
impl<St> StreamExt for St where
St: Stream + ?Sized, [src]pub fn next(&mut self) -> Next<'_, Self> where
Self: Unpin, [src]
Self: Unpin,
pub fn try_next<T, E>(&mut self) -> TryNext<'_, Self> where
Self: Stream<Item = Result<T, E>> + Unpin, [src]
Self: Stream<Item = Result<T, E>> + Unpin,
pub fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T, [src]
F: FnMut(Self::Item) -> T,
pub fn merge<U>(self, other: U) -> Merge<Self, U> where
U: Stream<Item = Self::Item>, [src]
U: Stream<Item = Self::Item>,
pub fn filter<F>(self, f: F) -> Filter<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
pub fn filter_map<T, F>(self, f: F) -> FilterMap<Self, F> where
F: FnMut(Self::Item) -> Option<T>, [src]
F: FnMut(Self::Item) -> Option<T>,
pub fn fuse(self) -> Fuse<Self>[src]
pub fn take(self, n: usize) -> Take<Self>[src]
pub fn take_while<F>(self, f: F) -> TakeWhile<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
pub fn skip(self, n: usize) -> Skip<Self>[src]
pub fn skip_while<F>(self, f: F) -> SkipWhile<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
pub fn all<F>(&mut self, f: F) -> AllFuture<'_, Self, F> where
Self: Unpin,
F: FnMut(Self::Item) -> bool, [src]
Self: Unpin,
F: FnMut(Self::Item) -> bool,
pub fn any<F>(&mut self, f: F) -> AnyFuture<'_, Self, F> where
Self: Unpin,
F: FnMut(Self::Item) -> bool, [src]
Self: Unpin,
F: FnMut(Self::Item) -> bool,
pub fn chain<U>(self, other: U) -> Chain<Self, U> where
U: Stream<Item = Self::Item>, [src]
U: Stream<Item = Self::Item>,
pub fn fold<B, F>(self, init: B, f: F) -> FoldFuture<Self, B, F> where
F: FnMut(B, Self::Item) -> B, [src]
F: FnMut(B, Self::Item) -> B,
pub fn collect<T>(self) -> Collect<Self, T> where
T: FromStream<Self::Item>, [src]
T: FromStream<Self::Item>,