Struct monoio_http::h1::codec::encoder::GenericEncoder
source · pub struct GenericEncoder<T> { /* private fields */ }Expand description
Encoder for Request or Response(in fact it is not a encoder literally, it is with io, like FramedWrite).
Implementations§
source§impl<T> GenericEncoder<T>
impl<T> GenericEncoder<T>
Trait Implementations§
source§impl<T, R> Sink<R> for GenericEncoder<T>where
T: AsyncWriteRent,
R: IntoParts<Body = Payload>,
R::Parts: ParamMut<HeaderMap>,
HeadEncoder: Encoder<R::Parts>,
<HeadEncoder as Encoder<R::Parts>>::Error: Into<EncodeError>,
impl<T, R> Sink<R> for GenericEncoder<T>where T: AsyncWriteRent, R: IntoParts<Body = Payload>, R::Parts: ParamMut<HeaderMap>, HeadEncoder: Encoder<R::Parts>, <HeadEncoder as Encoder<R::Parts>>::Error: Into<EncodeError>,
§type Error = EncodeError
type Error = EncodeError
The type of value produced by the sink when an error occurs.
§type SendFuture<'a>
where
Self: 'a,
R: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a
type SendFuture<'a> where Self: 'a, R: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a
Future representing the send result.
§type FlushFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a
type FlushFuture<'a> where Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a
Future representing the flush result.
§type CloseFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a
type CloseFuture<'a> where Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>> + 'a
Future representing the close result.
source§fn send<'a>(&'a mut self, item: R) -> Self::SendFuture<'a>where
R: 'a,
fn send<'a>(&'a mut self, item: R) -> Self::SendFuture<'a>where R: 'a,
Send item.
source§fn flush(&mut self) -> Self::FlushFuture<'_>
fn flush(&mut self) -> Self::FlushFuture<'_>
Flush any remaining output from this sink.
source§fn close(&mut self) -> Self::CloseFuture<'_>
fn close(&mut self) -> Self::CloseFuture<'_>
Flush any remaining output and close this sink, if necessary.
Auto Trait Implementations§
impl<T> RefUnwindSafe for GenericEncoder<T>where T: RefUnwindSafe,
impl<T> Send for GenericEncoder<T>where T: Send,
impl<T> Sync for GenericEncoder<T>where T: Sync,
impl<T> Unpin for GenericEncoder<T>where T: Unpin,
impl<T> UnwindSafe for GenericEncoder<T>where T: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T, A> SinkExt<T> for Awhere
A: Sink<T>,
impl<T, A> SinkExt<T> for Awhere A: Sink<T>,
§type SendFlushFuture = impl Future<Output = Result<(), <A as Sink<T>>::Error>> + 'a
type SendFlushFuture = impl Future<Output = Result<(), <A as Sink<T>>::Error>> + 'a
SendFlushFuture.
source§fn send_and_flush<'a>(
&'a mut self,
item: T
) -> <A as SinkExt<T>>::SendFlushFuture<'a>where
T: 'a,
fn send_and_flush<'a>( &'a mut self, item: T ) -> <A as SinkExt<T>>::SendFlushFuture<'a>where T: 'a,
Send and flush.