Struct async_http_codec::BodyDecodeWithContinueState

pub struct BodyDecodeWithContinueState { /* private fields */ }

Implementations

impl BodyDecodeWithContinueState

pub fn from_head(head: &RequestHead<'_>) -> Result<Self>

pub fn new(version: Version, length: Option<u64>, send_continue: bool) -> Self

pub fn from_headers(headers: &HeaderMap, version: Version) -> Result<Self>

pub fn into_async_read<IO: AsyncRead + AsyncWrite + Unpin>( self, io: IO ) -> BodyDecodeWithContinue<Self, IO>

pub fn as_async_read<IO: AsyncRead + AsyncWrite + Unpin>( &mut self, io: IO ) -> BodyDecodeWithContinue<&mut Self, IO>

pub fn poll_read<IO: AsyncRead + AsyncWrite + Unpin>( &mut self, cx: &mut Context<'_>, buf: &mut [u8], io: &mut IO ) -> Poll<Result<usize>>