Struct monoio_http::h1::codec::ServerCodec
source · [−]pub struct ServerCodec<IO> { /* private fields */ }Implementations
sourceimpl<IO> ServerCodec<IO>
impl<IO> ServerCodec<IO>
Trait Implementations
sourceimpl<IO> FillPayload for ServerCodec<IO>where
RequestDecoder<OwnedReadHalf<IO>>: FillPayload,
impl<IO> FillPayload for ServerCodec<IO>where
RequestDecoder<OwnedReadHalf<IO>>: FillPayload,
type Error = <GenericDecoder<OwnedReadHalf<IO>, GenericHeadDecoder<Request<Payload<Bytes, PayloadError>>, RequestHeadDecoder>> as FillPayload>::Error
type FillPayloadFuture<'a>
where
Self: 'a = <GenericDecoder<OwnedReadHalf<IO>, GenericHeadDecoder<Request<Payload<Bytes, PayloadError>>, RequestHeadDecoder>> as FillPayload>::FillPayloadFuture<'a>
fn fill_payload(&mut self) -> Self::FillPayloadFuture<'_>
sourceimpl<IO, R> Sink<R> for ServerCodec<IO>where
GenericEncoder<OwnedWriteHalf<IO>>: Sink<R>,
impl<IO, R> Sink<R> for ServerCodec<IO>where
GenericEncoder<OwnedWriteHalf<IO>>: Sink<R>,
type Error = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::Error
type Error = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::Error
The type of value produced by the sink when an error occurs.
type SendFuture<'a>
where
Self: 'a = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::SendFuture<'a>
type SendFuture<'a>
where
Self: 'a = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::SendFuture<'a>
Future representing the send result.
type FlushFuture<'a>
where
Self: 'a = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::FlushFuture<'a>
type FlushFuture<'a>
where
Self: 'a = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::FlushFuture<'a>
Future representing the flush result.
type CloseFuture<'a>
where
Self: 'a = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::CloseFuture<'a>
type CloseFuture<'a>
where
Self: 'a = <GenericEncoder<OwnedWriteHalf<IO>> as Sink<R>>::CloseFuture<'a>
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.
sourceimpl<IO> Stream for ServerCodec<IO>where
RequestDecoder<OwnedReadHalf<IO>>: Stream,
impl<IO> Stream for ServerCodec<IO>where
RequestDecoder<OwnedReadHalf<IO>>: Stream,
type Item = <GenericDecoder<OwnedReadHalf<IO>, GenericHeadDecoder<Request<Payload<Bytes, PayloadError>>, RequestHeadDecoder>> as Stream>::Item
type Item = <GenericDecoder<OwnedReadHalf<IO>, GenericHeadDecoder<Request<Payload<Bytes, PayloadError>>, RequestHeadDecoder>> as Stream>::Item
Values yielded by the stream.
type NextFuture<'a>
where
Self: 'a = <GenericDecoder<OwnedReadHalf<IO>, GenericHeadDecoder<Request<Payload<Bytes, PayloadError>>, RequestHeadDecoder>> as Stream>::NextFuture<'a>
type NextFuture<'a>
where
Self: 'a = <GenericDecoder<OwnedReadHalf<IO>, GenericHeadDecoder<Request<Payload<Bytes, PayloadError>>, RequestHeadDecoder>> as Stream>::NextFuture<'a>
Future representing the next value of the stream.
sourcefn next(&mut self) -> Self::NextFuture<'_>
fn next(&mut self) -> Self::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. Read moreAuto Trait Implementations
impl<IO> !RefUnwindSafe for ServerCodec<IO>
impl<IO> !Send for ServerCodec<IO>
impl<IO> !Sync for ServerCodec<IO>
impl<IO> Unpin for ServerCodec<IO>
impl<IO> !UnwindSafe for ServerCodec<IO>
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.
sourceimpl<T> StreamExt for Twhere
T: Stream,
impl<T> StreamExt for Twhere
T: Stream,
sourcefn map<T, F>(self, f: F) -> Map<Self, F>where
F: FnMut(Self::Item) -> T,
fn map<T, F>(self, f: F) -> Map<Self, F>where
F: FnMut(Self::Item) -> T,
Maps a stream to a stream of its items.