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
sourceimpl<T> GenericEncoder<T>
impl<T> GenericEncoder<T>
Trait Implementations
sourceimpl<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 = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>>
type SendFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>>
Future representing the send result.
type FlushFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>>
type FlushFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>>
Future representing the flush result.
type CloseFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>>
type CloseFuture<'a>
where
Self: 'a = impl Future<Output = Result<(), <GenericEncoder<T> as Sink<R>>::Error>>
Future representing the close result.
sourcefn send(&mut self, item: R) -> Self::SendFuture<'_>
fn send(&mut self, item: R) -> Self::SendFuture<'_>
Send item.
sourcefn flush(&mut self) -> Self::FlushFuture<'_>
fn flush(&mut self) -> Self::FlushFuture<'_>
Flush any remaining output from this sink.
sourcefn 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
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T, A> SinkExt<T> for Awhere
A: Sink<T>,
impl<T, A> SinkExt<T> for Awhere
A: Sink<T>,
sourcefn send_and_flush(&mut self, item: T) -> <A as SinkExt<T>>::SendFlushFuture<'_>
fn send_and_flush(&mut self, item: T) -> <A as SinkExt<T>>::SendFlushFuture<'_>
Send and flush.