Struct monoio_http::h1::FramedRead

pub struct FramedRead<IO, Codec> { /* private fields */ }

Implementations

impl<IO, Codec> FramedRead<IO, Codec>

pub fn new(io: IO, decoder: Codec) -> FramedRead<IO, Codec>

pub fn with_capacity( io: IO, codec: Codec, capacity: usize ) -> FramedRead<IO, Codec>

pub fn get_ref(&self) -> &IO

Returns a reference to the underlying I/O stream wrapped by FramedRead.

Note that care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.

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

Returns a mutable reference to the underlying I/O stream wrapped by FramedRead.

Note that care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.

pub fn into_inner(self) -> IO

Consumes the FramedRead, returning its underlying I/O stream.

Note that care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.

pub fn decoder(&self) -> &Codec

Returns a reference to the underlying decoder.

pub fn decoder_mut(&mut self) -> &mut Codec

Returns a mutable reference to the underlying decoder.

pub fn map_decoder<CodecNew, F>(self, map: F) -> FramedRead<IO, CodecNew>where F: FnOnce(Codec) -> CodecNew,

Maps the decoder D to C, preserving the read buffer wrapped by Framed.

pub fn read_buffer(&self) -> &BytesMut

Returns a reference to the read buffer.

pub fn read_buffer_mut(&mut self) -> &mut BytesMut

Returns a mutable reference to the read buffer.

pub async fn next_with<C>( &mut self, codec: &mut C ) -> impl Future<Output = Option<Result<<C as Decoder>::Item, <C as Decoder>::Error>>>where C: Decoder, IO: AsyncReadRent,

Equivalent to Stream::next but with custom codec.

Trait Implementations

impl<T, D> Debug for FramedRead<T, D>where T: Debug, D: Debug,

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

Formats the value using the given formatter.

impl<Codec, IO, AnyCodec> NextWithCodec<Codec> for FramedRead<IO, AnyCodec>where Codec: Decoder, IO: AsyncReadRent,

type Item = Result<<Codec as Decoder>::Item, <Codec as Decoder>::Error>

type NextFuture<'a> = impl Future<Output = Option<<FramedRead<IO, AnyCodec> as NextWithCodec<Codec>>::Item>> + 'a where FramedRead<IO, AnyCodec>: 'a, Codec: 'a

fn next_with<'a>( &'a mut self, codec: &'a mut Codec ) -> <FramedRead<IO, AnyCodec> as NextWithCodec<Codec>>::NextFuture<'a>

impl<IO, Codec> Stream for FramedRead<IO, Codec>where IO: AsyncReadRent, Codec: Decoder,

type Item = <FramedInner<IO, Codec, ReadState> as Stream>::Item

Values yielded by the stream.

type NextFuture<'a> = <FramedInner<IO, Codec, ReadState> as Stream>::NextFuture<'a> where FramedRead<IO, Codec>: 'a

Future representing the next value of the stream.

fn next(&mut self) -> <FramedRead<IO, Codec> as Stream>::NextFuture<'_>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.