Struct monoio_http::util::split::OwnedReadHalf

source · [−]

pub struct OwnedReadHalf<T>(_);

Expand description

OwnedReadHalf.

Trait Implementations

source

impl<IO> AsyncReadRent for OwnedReadHalf<IO>where
IO: AsyncReadRent,

type ReadFuture<'a, B>
where
B: IoBufMut + 'a,
Self: 'a = impl Future<Output = (Result<usize, Error>, B)>

The future of read Result<size, buffer>

type ReadvFuture<'a, B>
where
B: IoVecBufMut + 'a,
Self: 'a = impl Future<Output = (Result<usize, Error>, B)>

The future of readv Result<size, buffer>

source

fn read<T: IoBufMut>(&mut self, buf: T) -> Self::ReadFuture<'_, T>

Same as read(2)

source

fn readv<T: IoVecBufMut>(&mut self, buf: T) -> Self::ReadvFuture<'_, T>

Same as readv(2)

source

impl<T: Debug> Debug for OwnedReadHalf<T>

source

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl<T> !RefUnwindSafe for OwnedReadHalf<T>

impl<T> !Send for OwnedReadHalf<T>

impl<T> !Sync for OwnedReadHalf<T>

impl<T> Unpin for OwnedReadHalf<T>

impl<T> !UnwindSafe for OwnedReadHalf<T>

Blanket Implementations

source

impl<T> Any for Twhere
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<A> AsyncReadRentExt for Awhere
A: AsyncReadRent + ?Sized,

type ReadExactFuture = impl Future<Output = (Result<usize, Error>, T)>

The future of Result<size, buffer>

source

fn read_exact<T>(
 &mut self,
 buf: T
) -> <A as AsyncReadRentExt>::ReadExactFuture<'_, T>where
 T: 'static + IoBufMut,

Read until buf capacity is fulfilled

type ReadVectoredExactFuture = impl Future<Output = (Result<usize, Error>, T)>

The future of Result<size, buffer>

source

fn read_vectored_exact<T>(
 &mut self,
 buf: T
) -> <A as AsyncReadRentExt>::ReadVectoredExactFuture<'_, T>where
 T: 'static + IoVecBufMut,

Readv until buf capacity is fulfilled

type ReadU8Future = impl Future<Output = Result<u8, Error>>

Read number result

source

fn read_u8(&mut self) -> <A as AsyncReadRentExt>::ReadU8Future<'_>

Read number in async way

type ReadU16Future = impl Future<Output = Result<u16, Error>>

Read number result

source

fn read_u16(&mut self) -> <A as AsyncReadRentExt>::ReadU16Future<'_>

Read number in async way

type ReadU32Future = impl Future<Output = Result<u32, Error>>

Read number result

source

fn read_u32(&mut self) -> <A as AsyncReadRentExt>::ReadU32Future<'_>

Read number in async way

type ReadU64Future = impl Future<Output = Result<u64, Error>>

Read number result

source

fn read_u64(&mut self) -> <A as AsyncReadRentExt>::ReadU64Future<'_>

Read number in async way

type ReadU128Future = impl Future<Output = Result<u16, Error>>

Read number result

source

fn read_u128(&mut self) -> <A as AsyncReadRentExt>::ReadU128Future<'_>

Read number in async way

type ReadI8Future = impl Future<Output = Result<i8, Error>>

Read number result

source

fn read_i8(&mut self) -> <A as AsyncReadRentExt>::ReadI8Future<'_>

Read number in async way

type ReadI16Future = impl Future<Output = Result<i16, Error>>

Read number result

source

fn read_i16(&mut self) -> <A as AsyncReadRentExt>::ReadI16Future<'_>

Read number in async way

type ReadI32Future = impl Future<Output = Result<i32, Error>>

Read number result

source

fn read_i32(&mut self) -> <A as AsyncReadRentExt>::ReadI32Future<'_>

Read number in async way

type ReadI64Future = impl Future<Output = Result<i64, Error>>

Read number result

source

fn read_i64(&mut self) -> <A as AsyncReadRentExt>::ReadI64Future<'_>

Read number in async way

type ReadI128Future = impl Future<Output = Result<i128, Error>>

Read number result

source

fn read_i128(&mut self) -> <A as AsyncReadRentExt>::ReadI128Future<'_>

Read number in async way

type ReadF32Future = impl Future<Output = Result<f32, Error>>

Read number result

source

fn read_f32(&mut self) -> <A as AsyncReadRentExt>::ReadF32Future<'_>

Read number in async way

type ReadF64Future = impl Future<Output = Result<f64, Error>>

Read number result

source

fn read_f64(&mut self) -> <A as AsyncReadRentExt>::ReadF64Future<'_>

Read number in async way

type ReadU8LEFuture = impl Future<Output = Result<u8, Error>>

Read number result

source

fn read_u8_le(&mut self) -> <A as AsyncReadRentExt>::ReadU8LEFuture<'_>

Read number in async way

type ReadU16LEFuture = impl Future<Output = Result<u16, Error>>

Read number result

source

fn read_u16_le(&mut self) -> <A as AsyncReadRentExt>::ReadU16LEFuture<'_>

Read number in async way

type ReadU32LEFuture = impl Future<Output = Result<u32, Error>>

Read number result

source

fn read_u32_le(&mut self) -> <A as AsyncReadRentExt>::ReadU32LEFuture<'_>

Read number in async way

type ReadU64LEFuture = impl Future<Output = Result<u64, Error>>

Read number result

source

fn read_u64_le(&mut self) -> <A as AsyncReadRentExt>::ReadU64LEFuture<'_>

Read number in async way

type ReadU128LEFuture = impl Future<Output = Result<u16, Error>>

Read number result

source

fn read_u128_le(&mut self) -> <A as AsyncReadRentExt>::ReadU128LEFuture<'_>

Read number in async way

type ReadI8LEFuture = impl Future<Output = Result<i8, Error>>

Read number result

source

fn read_i8_le(&mut self) -> <A as AsyncReadRentExt>::ReadI8LEFuture<'_>

Read number in async way

type ReadI16LEFuture = impl Future<Output = Result<i16, Error>>

Read number result

source

fn read_i16_le(&mut self) -> <A as AsyncReadRentExt>::ReadI16LEFuture<'_>

Read number in async way

type ReadI32LEFuture = impl Future<Output = Result<i32, Error>>

Read number result

source

fn read_i32_le(&mut self) -> <A as AsyncReadRentExt>::ReadI32LEFuture<'_>

Read number in async way

type ReadI64LEFuture = impl Future<Output = Result<i64, Error>>

Read number result

source

fn read_i64_le(&mut self) -> <A as AsyncReadRentExt>::ReadI64LEFuture<'_>

Read number in async way

type ReadI128LEFuture = impl Future<Output = Result<i128, Error>>

Read number result

source

fn read_i128_le(&mut self) -> <A as AsyncReadRentExt>::ReadI128LEFuture<'_>

Read number in async way

type ReadF32LEFuture = impl Future<Output = Result<f32, Error>>

Read number result

source

fn read_f32_le(&mut self) -> <A as AsyncReadRentExt>::ReadF32LEFuture<'_>

Read number in async way

type ReadF64LEFuture = impl Future<Output = Result<f64, Error>>

Read number result

source

fn read_f64_le(&mut self) -> <A as AsyncReadRentExt>::ReadF64LEFuture<'_>

Read number in async way

source

impl<T> Borrow<T> for Twhere
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for Twhere
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source

impl<T, U> TryFrom for Twhere
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for Twhere
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct monoio_http::util::split::OwnedReadHalf

Trait Implementations

impl<IO> AsyncReadRent for OwnedReadHalf<IO>where IO: AsyncReadRent,

type ReadFuture<'a, B>where B: IoBufMut + 'a, Self: 'a = impl Future<Output = (Result<usize, Error>, B)>

type ReadvFuture<'a, B>where B: IoVecBufMut + 'a, Self: 'a = impl Future<Output = (Result<usize, Error>, B)>

fn read<T: IoBufMut>(&mut self, buf: T) -> Self::ReadFuture<'_, T>

fn readv<T: IoVecBufMut>(&mut self, buf: T) -> Self::ReadvFuture<'_, T>

impl<T: Debug> Debug for OwnedReadHalf<T>

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

Auto Trait Implementations

impl<T> !RefUnwindSafe for OwnedReadHalf<T>

impl<T> !Send for OwnedReadHalf<T>

impl<T> !Sync for OwnedReadHalf<T>

impl<T> Unpin for OwnedReadHalf<T>

impl<T> !UnwindSafe for OwnedReadHalf<T>

Blanket Implementations

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<A> AsyncReadRentExt for Awhere A: AsyncReadRent + ?Sized,

type ReadExactFuture = impl Future<Output = (Result<usize, Error>, T)>

fn read_exact<T>( &mut self, buf: T) -> <A as AsyncReadRentExt>::ReadExactFuture<'_, T>where T: 'static + IoBufMut,

type ReadVectoredExactFuture = impl Future<Output = (Result<usize, Error>, T)>

fn read_vectored_exact<T>( &mut self, buf: T) -> <A as AsyncReadRentExt>::ReadVectoredExactFuture<'_, T>where T: 'static + IoVecBufMut,

type ReadU8Future = impl Future<Output = Result<u8, Error>>

fn read_u8(&mut self) -> <A as AsyncReadRentExt>::ReadU8Future<'_>

type ReadU16Future = impl Future<Output = Result<u16, Error>>

fn read_u16(&mut self) -> <A as AsyncReadRentExt>::ReadU16Future<'_>

type ReadU32Future = impl Future<Output = Result<u32, Error>>

fn read_u32(&mut self) -> <A as AsyncReadRentExt>::ReadU32Future<'_>

type ReadU64Future = impl Future<Output = Result<u64, Error>>

fn read_u64(&mut self) -> <A as AsyncReadRentExt>::ReadU64Future<'_>

type ReadU128Future = impl Future<Output = Result<u16, Error>>

fn read_u128(&mut self) -> <A as AsyncReadRentExt>::ReadU128Future<'_>

type ReadI8Future = impl Future<Output = Result<i8, Error>>

fn read_i8(&mut self) -> <A as AsyncReadRentExt>::ReadI8Future<'_>

type ReadI16Future = impl Future<Output = Result<i16, Error>>

fn read_i16(&mut self) -> <A as AsyncReadRentExt>::ReadI16Future<'_>

type ReadI32Future = impl Future<Output = Result<i32, Error>>

fn read_i32(&mut self) -> <A as AsyncReadRentExt>::ReadI32Future<'_>

type ReadI64Future = impl Future<Output = Result<i64, Error>>

fn read_i64(&mut self) -> <A as AsyncReadRentExt>::ReadI64Future<'_>

type ReadI128Future = impl Future<Output = Result<i128, Error>>

fn read_i128(&mut self) -> <A as AsyncReadRentExt>::ReadI128Future<'_>

type ReadF32Future = impl Future<Output = Result<f32, Error>>

fn read_f32(&mut self) -> <A as AsyncReadRentExt>::ReadF32Future<'_>

type ReadF64Future = impl Future<Output = Result<f64, Error>>

fn read_f64(&mut self) -> <A as AsyncReadRentExt>::ReadF64Future<'_>

type ReadU8LEFuture = impl Future<Output = Result<u8, Error>>

fn read_u8_le(&mut self) -> <A as AsyncReadRentExt>::ReadU8LEFuture<'_>

type ReadU16LEFuture = impl Future<Output = Result<u16, Error>>

fn read_u16_le(&mut self) -> <A as AsyncReadRentExt>::ReadU16LEFuture<'_>

type ReadU32LEFuture = impl Future<Output = Result<u32, Error>>

fn read_u32_le(&mut self) -> <A as AsyncReadRentExt>::ReadU32LEFuture<'_>

type ReadU64LEFuture = impl Future<Output = Result<u64, Error>>

fn read_u64_le(&mut self) -> <A as AsyncReadRentExt>::ReadU64LEFuture<'_>

type ReadU128LEFuture = impl Future<Output = Result<u16, Error>>

fn read_u128_le(&mut self) -> <A as AsyncReadRentExt>::ReadU128LEFuture<'_>

type ReadI8LEFuture = impl Future<Output = Result<i8, Error>>

fn read_i8_le(&mut self) -> <A as AsyncReadRentExt>::ReadI8LEFuture<'_>

type ReadI16LEFuture = impl Future<Output = Result<i16, Error>>

fn read_i16_le(&mut self) -> <A as AsyncReadRentExt>::ReadI16LEFuture<'_>

type ReadI32LEFuture = impl Future<Output = Result<i32, Error>>

fn read_i32_le(&mut self) -> <A as AsyncReadRentExt>::ReadI32LEFuture<'_>

type ReadI64LEFuture = impl Future<Output = Result<i64, Error>>

fn read_i64_le(&mut self) -> <A as AsyncReadRentExt>::ReadI64LEFuture<'_>

type ReadI128LEFuture = impl Future<Output = Result<i128, Error>>

fn read_i128_le(&mut self) -> <A as AsyncReadRentExt>::ReadI128LEFuture<'_>

type ReadF32LEFuture = impl Future<Output = Result<f32, Error>>

fn read_f32_le(&mut self) -> <A as AsyncReadRentExt>::ReadF32LEFuture<'_>

type ReadF64LEFuture = impl Future<Output = Result<f64, Error>>

fn read_f64_le(&mut self) -> <A as AsyncReadRentExt>::ReadF64LEFuture<'_>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<IO> AsyncReadRent for OwnedReadHalf<IO>where
IO: AsyncReadRent,

type ReadFuture<'a, B>
where
B: IoBufMut + 'a,
Self: 'a = impl Future<Output = (Result<usize, Error>, B)>

type ReadvFuture<'a, B>
where
B: IoVecBufMut + 'a,
Self: 'a = impl Future<Output = (Result<usize, Error>, B)>

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<A> AsyncReadRentExt for Awhere
A: AsyncReadRent + ?Sized,

fn read_exact<T>(
&mut self,
buf: T
) -> <A as AsyncReadRentExt>::ReadExactFuture<'_, T>where
T: 'static + IoBufMut,

fn read_vectored_exact<T>(
&mut self,
buf: T
) -> <A as AsyncReadRentExt>::ReadVectoredExactFuture<'_, T>where
T: 'static + IoVecBufMut,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,