Struct async_compression::stream::LzmaEncoder [−][src]
pub struct LzmaEncoder<S> { /* fields omitted */ }
See async-compression::stream
docs for migration
stream
and lzma
only.A lzma encoder, or compressor.
This structure implements a Stream
interface and will read
uncompressed data from an underlying stream and emit a stream of compressed data.
Implementations
impl<S: Stream<Item = Result<Bytes>>> LzmaEncoder<S>
[src]
impl<S: Stream<Item = Result<Bytes>>> LzmaEncoder<S>
[src]pub fn new(inner: S) -> Self
[src]
See async-compression::stream
docs for migration
Creates a new encoder which will read uncompressed data from the given stream and emit a compressed stream.
pub fn with_quality(inner: S, level: Level) -> Self
[src]
See async-compression::stream
docs for migration
Creates a new encoder which will read uncompressed data from the given stream and emit a compressed stream.
pub fn get_ref(&self) -> &S
[src]
See async-compression::stream
docs for migration
Acquires a reference to the underlying stream that this encoder 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 encoder is wrapping.
Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this encoder.
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 encoder is wrapping.
Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this encoder.
pub fn into_inner(self) -> S
[src]
See async-compression::stream
docs for migration
Consumes this encoder returning the underlying stream.
Note that this may discard internal state of this encoder, so care should be taken to avoid losing resources when this is called.
Trait Implementations
impl<'__pin, S> Unpin for LzmaEncoder<S> where
__Origin<'__pin, S>: Unpin,
[src]
impl<'__pin, S> Unpin for LzmaEncoder<S> where
__Origin<'__pin, S>: Unpin,
[src]Auto Trait Implementations
impl<S> RefUnwindSafe for LzmaEncoder<S> where
S: RefUnwindSafe,
impl<S> RefUnwindSafe for LzmaEncoder<S> where
S: RefUnwindSafe,
impl<S> Send for LzmaEncoder<S> where
S: Send,
impl<S> Send for LzmaEncoder<S> where
S: Send,
impl<S> Sync for LzmaEncoder<S> where
S: Sync,
impl<S> Sync for LzmaEncoder<S> where
S: Sync,
impl<S> UnwindSafe for LzmaEncoder<S> where
S: UnwindSafe,
impl<S> UnwindSafe for LzmaEncoder<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>,