Struct wrpc_transport::Incoming

source · 
pub struct Incoming<T> { /* private fields */ }
Expand description

Buffered incoming stream used for decoding values

Trait Implementations§

source§

impl<T: AsyncRead + Unpin> AsyncRead for Incoming<T>

source§

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf. Read more
source§

impl<R, T: ?Sized> Deferred<Incoming<R>> for CoreVecDecoder<ResourceBorrowDecoder<T>>

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, T: ?Sized> Deferred<Incoming<R>> for CoreVecDecoder<ResourceOwnDecoder<T>>

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<T, R> Deferred<Incoming<R>> for FutureDecoder<T, R>
where T: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<T, R> Deferred<Incoming<R>> for ListDecoder<T, R>
where T: Decoder, R: Index<R> + Send + Sync + 'static,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, T: ?Sized> Deferred<Incoming<R>> for ResourceBorrowDecoder<T>

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, T: ?Sized> Deferred<Incoming<R>> for ResourceOwnDecoder<T>

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<T, R> Deferred<Incoming<R>> for StreamDecoder<T, R>
where T: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R> Deferred<Incoming<R>> for StreamDecoderBytes<R>

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R> Deferred<Incoming<R>> for StreamDecoderRead<R>

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder,), (Option<V0>,)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder), (Option<V0>, Option<V1>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder), (Option<V0>, Option<V1>, Option<V2>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9, V10> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder, V10::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>, Option<V10>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>, V10: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9, V10, V11> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder, V10::Decoder, V11::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>, Option<V10>, Option<V11>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>, V10: Decode<R>, V11: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9, V10, V11, V12> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder, V10::Decoder, V11::Decoder, V12::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>, Option<V10>, Option<V11>, Option<V12>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>, V10: Decode<R>, V11: Decode<R>, V12: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9, V10, V11, V12, V13> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder, V10::Decoder, V11::Decoder, V12::Decoder, V13::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>, Option<V10>, Option<V11>, Option<V12>, Option<V13>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>, V10: Decode<R>, V11: Decode<R>, V12: Decode<R>, V13: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9, V10, V11, V12, V13, V14> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder, V10::Decoder, V11::Decoder, V12::Decoder, V13::Decoder, V14::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>, Option<V10>, Option<V11>, Option<V12>, Option<V13>, Option<V14>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>, V10: Decode<R>, V11: Decode<R>, V12: Decode<R>, V13: Decode<R>, V14: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<R, V0, V1, V2, V3, V4, V5, V6, V7, V8, V9, V10, V11, V12, V13, V14, V15> Deferred<Incoming<R>> for TupleDecoder<(V0::Decoder, V1::Decoder, V2::Decoder, V3::Decoder, V4::Decoder, V5::Decoder, V6::Decoder, V7::Decoder, V8::Decoder, V9::Decoder, V10::Decoder, V11::Decoder, V12::Decoder, V13::Decoder, V14::Decoder, V15::Decoder), (Option<V0>, Option<V1>, Option<V2>, Option<V3>, Option<V4>, Option<V5>, Option<V6>, Option<V7>, Option<V8>, Option<V9>, Option<V10>, Option<V11>, Option<V12>, Option<V13>, Option<V14>, Option<V15>)>
where R: Index<R> + Send + Sync + 'static, V0: Decode<R>, V1: Decode<R>, V2: Decode<R>, V3: Decode<R>, V4: Decode<R>, V5: Decode<R>, V6: Decode<R>, V7: Decode<R>, V8: Decode<R>, V9: Decode<R>, V10: Decode<R>, V11: Decode<R>, V12: Decode<R>, V13: Decode<R>, V14: Decode<R>, V15: Decode<R>,

source§

fn take_deferred(&mut self) -> Option<DeferredFn<Incoming<R>>>

Takes a deferred async processing operation, if any
source§

impl<T: Index<T>> Index<Incoming<T>> for Incoming<T>

source§

fn index(&self, path: &[usize]) -> Result<Self>

Index the entity using a structural path

Auto Trait Implementations§

§

impl<T> Freeze for Incoming<T>
where T: Freeze,

§

impl<T> RefUnwindSafe for Incoming<T>
where T: RefUnwindSafe,

§

impl<T> Send for Incoming<T>
where T: Send,

§

impl<T> Sync for Incoming<T>
where T: Sync,

§

impl<T> Unpin for Incoming<T>
where T: Unpin,

§

impl<T> UnwindSafe for Incoming<T>
where T: UnwindSafe,

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> AsyncReadCore for T
where T: AsyncRead,

source§

fn read_core_name( &mut self, s: &mut String, ) -> impl Future<Output = Result<(), Error>>
where Self: Sized + Unpin,

Read core:name
source§

impl<R> AsyncReadExt for R
where R: AsyncRead + ?Sized,

source§

fn chain<R>(self, next: R) -> Chain<Self, R>
where Self: Sized, R: AsyncRead,

Creates a new AsyncRead instance that chains this stream with next. Read more
source§

fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>
where Self: Unpin,

Pulls some bytes from this source into the specified buffer, returning how many bytes were read. Read more
source§

fn read_buf<'a, B>(&'a mut self, buf: &'a mut B) -> ReadBuf<'a, Self, B>
where Self: Unpin, B: BufMut + ?Sized,

Pulls some bytes from this source into the specified buffer, advancing the buffer’s internal cursor. Read more
source§

fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self>
where Self: Unpin,

Reads the exact number of bytes required to fill buf. Read more
source§

fn read_u8(&mut self) -> ReadU8<&mut Self>
where Self: Unpin,

Reads an unsigned 8 bit integer from the underlying reader. Read more
source§

fn read_i8(&mut self) -> ReadI8<&mut Self>
where Self: Unpin,

Reads a signed 8 bit integer from the underlying reader. Read more
source§

fn read_u16(&mut self) -> ReadU16<&mut Self>
where Self: Unpin,

Reads an unsigned 16-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_i16(&mut self) -> ReadI16<&mut Self>
where Self: Unpin,

Reads a signed 16-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_u32(&mut self) -> ReadU32<&mut Self>
where Self: Unpin,

Reads an unsigned 32-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_i32(&mut self) -> ReadI32<&mut Self>
where Self: Unpin,

Reads a signed 32-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_u64(&mut self) -> ReadU64<&mut Self>
where Self: Unpin,

Reads an unsigned 64-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_i64(&mut self) -> ReadI64<&mut Self>
where Self: Unpin,

Reads an signed 64-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_u128(&mut self) -> ReadU128<&mut Self>
where Self: Unpin,

Reads an unsigned 128-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_i128(&mut self) -> ReadI128<&mut Self>
where Self: Unpin,

Reads an signed 128-bit integer in big-endian order from the underlying reader. Read more
source§

fn read_f32(&mut self) -> ReadF32<&mut Self>
where Self: Unpin,

Reads an 32-bit floating point type in big-endian order from the underlying reader. Read more
source§

fn read_f64(&mut self) -> ReadF64<&mut Self>
where Self: Unpin,

Reads an 64-bit floating point type in big-endian order from the underlying reader. Read more
source§

fn read_u16_le(&mut self) -> ReadU16Le<&mut Self>
where Self: Unpin,

Reads an unsigned 16-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_i16_le(&mut self) -> ReadI16Le<&mut Self>
where Self: Unpin,

Reads a signed 16-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_u32_le(&mut self) -> ReadU32Le<&mut Self>
where Self: Unpin,

Reads an unsigned 32-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_i32_le(&mut self) -> ReadI32Le<&mut Self>
where Self: Unpin,

Reads a signed 32-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_u64_le(&mut self) -> ReadU64Le<&mut Self>
where Self: Unpin,

Reads an unsigned 64-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_i64_le(&mut self) -> ReadI64Le<&mut Self>
where Self: Unpin,

Reads an signed 64-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_u128_le(&mut self) -> ReadU128Le<&mut Self>
where Self: Unpin,

Reads an unsigned 128-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_i128_le(&mut self) -> ReadI128Le<&mut Self>
where Self: Unpin,

Reads an signed 128-bit integer in little-endian order from the underlying reader. Read more
source§

fn read_f32_le(&mut self) -> ReadF32Le<&mut Self>
where Self: Unpin,

Reads an 32-bit floating point type in little-endian order from the underlying reader. Read more
source§

fn read_f64_le(&mut self) -> ReadF64Le<&mut Self>
where Self: Unpin,

Reads an 64-bit floating point type in little-endian order from the underlying reader. Read more
source§

fn read_to_end<'a>(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEnd<'a, Self>
where Self: Unpin,

Reads all bytes until EOF in this source, placing them into buf. Read more
source§

fn read_to_string<'a>( &'a mut self, dst: &'a mut String, ) -> ReadToString<'a, Self>
where Self: Unpin,

Reads all bytes until EOF in this source, appending them to buf. Read more
source§

fn take(self, limit: u64) -> Take<Self>
where Self: Sized,

Creates an adaptor which reads at most limit bytes from it. Read more
source§

impl<T> AsyncReadLeb128 for T
where T: AsyncRead,

source§

fn read_u8_leb128(&mut self) -> impl Future<Output = Result<u8, Error>>
where Self: Unpin,

source§

fn read_u16_leb128(&mut self) -> impl Future<Output = Result<u16, Error>>
where Self: Unpin,

source§

fn read_u32_leb128(&mut self) -> impl Future<Output = Result<u32, Error>>
where Self: Unpin,

source§

fn read_u64_leb128(&mut self) -> impl Future<Output = Result<u64, Error>>
where Self: Unpin,

source§

fn read_u128_leb128(&mut self) -> impl Future<Output = Result<u128, Error>>
where Self: Unpin,

source§

fn read_var_u8_leb128( &mut self, n: u8, ) -> impl Future<Output = Result<u8, Error>>
where Self: Unpin,

source§

fn read_var_u16_leb128( &mut self, n: u8, ) -> impl Future<Output = Result<u16, Error>>
where Self: Unpin,

source§

fn read_var_u32_leb128( &mut self, n: u8, ) -> impl Future<Output = Result<u32, Error>>
where Self: Unpin,

source§

fn read_var_u64_leb128( &mut self, n: u8, ) -> impl Future<Output = Result<u64, Error>>
where Self: Unpin,

source§

fn read_var_u128_leb128( &mut self, n: u8, ) -> impl Future<Output = Result<u128, Error>>
where Self: Unpin,

source§

fn read_i8_leb128(&mut self) -> impl Future<Output = Result<i8, Error>>
where Self: Unpin,

source§

fn read_i16_leb128(&mut self) -> impl Future<Output = Result<i16, Error>>
where Self: Unpin,

source§

fn read_i32_leb128(&mut self) -> impl Future<Output = Result<i32, Error>>
where Self: Unpin,

source§

fn read_i64_leb128(&mut self) -> impl Future<Output = Result<i64, Error>>
where Self: Unpin,

source§

fn read_i128_leb128(&mut self) -> impl Future<Output = Result<i128, Error>>
where Self: Unpin,

source§

impl<T> AsyncReadUtf8 for T
where T: AsyncRead,

source§

fn read_char_utf8(&mut self) -> impl Future<Output = Result<char, Error>>
where Self: Unpin,

source§

impl<T> AsyncReadValue for T
where T: AsyncRead,

source§

fn read_bool(&mut self) -> impl Future<Output = Result<bool, Error>>
where Self: Unpin,

source§

fn read_option_status(&mut self) -> impl Future<Output = Result<bool, Error>>
where Self: Unpin,

source§

fn read_result_status(&mut self) -> impl Future<Output = Result<bool, Error>>
where Self: Unpin,

source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

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<U> for T
where U: From<T>,

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> TokioAsyncReadCompatExt for T
where T: AsyncRead,

source§

fn compat(self) -> Compat<Self>
where Self: Sized,

Wraps self with a compatibility layer that implements futures_io::AsyncRead.
source§

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

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

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

Performs the conversion.
source§

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

source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::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