Struct async_http_codec::internal::buffer_decode::BufferDecodeState

pub struct BufferDecodeState<O: 'static> { /* private fields */ }

Implementations

impl<O> BufferDecodeState<O>

pub fn new(
    max_buffer: usize,
    max_headers: usize,
    decode_func: &'static (dyn Fn(&[u8], usize) -> Result<O> + Sync)
) -> Self

Trait Implementations

impl<IO: AsyncRead + Unpin, O> IoFutureWithOutputState<IO, O> for BufferDecodeState<O>

fn poll(&mut self, cx: &mut Context<'_>, transport: &mut IO) -> Poll<Result<O>>

fn into_future(self, io: IO) -> IoFutureWithOutput<Self, IO, O>