Struct async_codec_util::Encoder

pub struct Encoder<W, C> { /* fields omitted */ }

Future for fully encoding an AsyncEncode into an AsyncWrite.

Methods

impl<W, C> Encoder<W, C>

pub fn new(writer: W, enc: C) -> Encoder<W, C>

Create a new Encoder wrapping an AsyncWrite and consuming an AsyncEncode.

impl<W, C> Encoder<W, C> where
    W: AsyncWrite,
    C: AsyncEncodeLen, 

pub fn remaining_bytes(&mut self) -> usize

Return the exact number of bytes this will still write.

Panics if called after the future completed.

Trait Implementations

impl<W, C> Future for Encoder<W, C> where
    W: AsyncWrite,
    C: AsyncEncode, 

type Item = (W, usize)

A successful value

type Error = (W, FutIoErr)

An error

fn poll(&mut self, cx: &mut Context) -> Poll<Self::Item, Self::Error>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.