[−][src]Struct async_compression::stream::ZlibEncoder
feature="stream" and feature="zlib" only.A zlib 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>>> ZlibEncoder<S>[src]
pub fn new(inner: S) -> Self[src]
feature="stream" only.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]
feature="stream" only.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]
feature="stream" only.Acquires a reference to the underlying stream that this encoder is wrapping.
pub fn get_mut(&mut self) -> &mut S[src]
feature="stream" only.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]
feature="stream" only.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]
feature="stream" only.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<S: Debug> Debug for ZlibEncoder<S>[src]
impl<S: Stream<Item = Result<Bytes>>> Stream for ZlibEncoder<S>[src]
type Item = Result<Bytes>
Values yielded by the stream.
fn poll_next(
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Option<Result<Bytes>>>[src]
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Option<Result<Bytes>>>
fn size_hint(&self) -> (usize, Option<usize>)[src]
impl<'__pin, S> Unpin for ZlibEncoder<S> where
__Origin<'__pin, S>: Unpin, [src]
__Origin<'__pin, S>: Unpin,
Auto Trait Implementations
impl<S> RefUnwindSafe for ZlibEncoder<S> where
S: RefUnwindSafe,
S: RefUnwindSafe,
impl<S> Send for ZlibEncoder<S> where
S: Send,
S: Send,
impl<S> Sync for ZlibEncoder<S> where
S: Sync,
S: Sync,
impl<S> UnwindSafe for ZlibEncoder<S> where
S: UnwindSafe,
S: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<St> StreamExt for St where
St: Stream + ?Sized, [src]
St: Stream + ?Sized,
fn next(&mut self) -> Next<Self> where
Self: Unpin, [src]
Self: Unpin,
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,
fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T, [src]
F: FnMut(Self::Item) -> T,
fn merge<U>(self, other: U) -> Merge<Self, U> where
U: Stream<Item = Self::Item>, [src]
U: Stream<Item = Self::Item>,
fn filter<F>(self, f: F) -> Filter<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
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>,
fn fuse(self) -> Fuse<Self>[src]
fn take(self, n: usize) -> Take<Self>[src]
fn take_while<F>(self, f: F) -> TakeWhile<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
fn skip(self, n: usize) -> Skip<Self>[src]
fn skip_while<F>(self, f: F) -> SkipWhile<Self, F> where
F: FnMut(&Self::Item) -> bool, [src]
F: FnMut(&Self::Item) -> bool,
fn all<F>(&mut self, f: F) -> AllFuture<Self, F> where
F: FnMut(Self::Item) -> bool,
Self: Unpin, [src]
F: FnMut(Self::Item) -> bool,
Self: Unpin,
fn any<F>(&mut self, f: F) -> AnyFuture<Self, F> where
F: FnMut(Self::Item) -> bool,
Self: Unpin, [src]
F: FnMut(Self::Item) -> bool,
Self: Unpin,
fn chain<U>(self, other: U) -> Chain<Self, U> where
U: Stream<Item = Self::Item>, [src]
U: Stream<Item = Self::Item>,
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,
fn collect<T>(self) -> Collect<Self, T> where
T: FromStream<Self::Item>, [src]
T: FromStream<Self::Item>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<S, T, E> TryStream for S where
S: Stream<Item = Result<T, E>> + ?Sized, [src]
S: Stream<Item = Result<T, E>> + ?Sized,