Struct h2::codec::framed_write::FramedWrite

pub struct FramedWrite<T, B> {
    inner: T,
    encoder: Encoder<B>,
}

Fields

inner: T

Upstream AsyncWrite

encoder: Encoder<B>

Implementations

impl<T, B> FramedWrite<T, B>

where T: AsyncWrite + Unpin, B: Buf,

pub fn new(inner: T) -> FramedWrite<T, B>

pub fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>>

Returns Ready when send is able to accept a frame

Calling this function may result in the current contents of the buffer to be flushed to T.

pub fn buffer(&mut self, item: Frame<B>) -> Result<(), UserError>

Buffer a frame.

poll_ready must be called first to ensure that a frame may be accepted.

pub fn flush(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>>

Flush buffered data to the wire

pub fn shutdown(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>>

Close the codec

impl<T, B> FramedWrite<T, B>

pub fn max_frame_size(&self) -> usize

Returns the max frame size that can be sent

pub fn set_max_frame_size(&mut self, val: usize)

Set the peer’s max frame size.

pub fn set_header_table_size(&mut self, val: usize)

Set the peer’s header table size.

pub fn take_last_data_frame(&mut self) -> Option<Data<B>>

Retrieve the last data frame that has been sent

pub fn get_mut(&mut self) -> &mut T

Trait Implementations

impl<T: AsyncRead + Unpin, B> AsyncRead for FramedWrite<T, B>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl<T: Debug, B: Debug> Debug for FramedWrite<T, B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Unpin, B> Unpin for FramedWrite<T, B>