Struct monoio_http::h1::codec::encoder::GenericEncoder

pub struct GenericEncoder<T> { /* private fields */ }

Encoder for Request or Response(in fact it is not a encoder literally, it is with io, like FramedWrite).

Implementations

impl<T> GenericEncoder<T>

pub fn new(io: T) -> Self

Trait Implementations

impl<T, R> Sink<R> for GenericEncoder<T>where T: AsyncWriteRent, R::Parts: BorrowHeaderMap, R: IntoParts, R::Body: Body, HeadEncoder: Encoder<R::Parts>, <HeadEncoder as Encoder<R::Parts>>::Error: Into<EncodeError>, EncodeError: From<<<R as IntoParts>::Body as Body>::Error>,

type Error = EncodeError

The type of value produced by the sink when an error occurs.

type SendFuture<'a> = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a where Self: 'a, R: 'a

Future representing the send result.

type FlushFuture<'a> = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a where Self: 'a

Future representing the flush result.

type CloseFuture<'a> = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a where Self: 'a

Future representing the close result.

fn send<'a>(&'a mut self, item: R) -> Self::SendFuture<'a>where R: 'a,

Send item.

fn flush(&mut self) -> Self::FlushFuture<'_>

Flush any remaining output from this sink.

fn close(&mut self) -> Self::CloseFuture<'_>

Flush any remaining output and close this sink, if necessary.