pub struct StoredFileData {
pub store_path: Arc<String>,
/* private fields */
}Expand description
本地存储文件数据
Fields§
§store_path: Arc<String>文件存储路径
Implementations§
source§impl StoredFileData
impl StoredFileData
sourcepub fn get_content_type(&self) -> Mime
pub fn get_content_type(&self) -> Mime
获取content-type
sourcepub fn get_file_name(&self) -> Cow<'_, str>
pub fn get_file_name(&self) -> Cow<'_, str>
获取文件名
sourcepub fn write_bytes(&mut self, buf: &[u8]) -> AppResult<()>
pub fn write_bytes(&mut self, buf: &[u8]) -> AppResult<()>
写入内容
Trait Implementations§
source§impl AsyncRead for StoredFileData
impl AsyncRead for StoredFileData
source§impl AsyncRead for StoredFileData
impl AsyncRead for StoredFileData
source§impl AsyncSeek for StoredFileData
impl AsyncSeek for StoredFileData
source§impl BinaryContent for StoredFileData
impl BinaryContent for StoredFileData
source§impl Clone for StoredFileData
impl Clone for StoredFileData
source§impl Debug for StoredFileData
impl Debug for StoredFileData
source§impl Drop for StoredFileData
impl Drop for StoredFileData
source§impl Read for StoredFileData
impl Read for StoredFileData
source§fn read(&mut self, buf: &mut [u8]) -> Result<usize>
fn read(&mut self, buf: &mut [u8]) -> Result<usize>
Pull some bytes from this source into the specified buffer, returning
how many bytes were read. Read more
1.36.0 · source§fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize, Error>
fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize, Error>
Like
read, except that it reads into a slice of buffers. Read moresource§fn is_read_vectored(&self) -> bool
fn is_read_vectored(&self) -> bool
🔬This is a nightly-only experimental API. (
can_vector)1.0.0 · source§fn read_to_end(&mut self, buf: &mut Vec<u8, Global>) -> Result<usize, Error>
fn read_to_end(&mut self, buf: &mut Vec<u8, Global>) -> Result<usize, Error>
Read all bytes until EOF in this source, placing them into
buf. Read more1.0.0 · source§fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
Read all bytes until EOF in this source, appending them to
buf. Read more1.6.0 · source§fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
Read the exact number of bytes required to fill
buf. Read moresource§fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>
fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>
🔬This is a nightly-only experimental API. (
read_buf)Pull some bytes from this source into the specified buffer. Read more
source§fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>
fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>
🔬This is a nightly-only experimental API. (
read_buf)Read the exact number of bytes required to fill
cursor. Read more1.0.0 · source§fn by_ref(&mut self) -> &mut Selfwhere
Self: Sized,
fn by_ref(&mut self) -> &mut Selfwhere Self: Sized,
Creates a “by reference” adaptor for this instance of
Read. Read moresource§impl Seek for StoredFileData
impl Seek for StoredFileData
source§fn seek(&mut self, pos: SeekFrom) -> Result<u64>
fn seek(&mut self, pos: SeekFrom) -> Result<u64>
Seek to an offset, in bytes, in a stream. Read more
1.55.0 · source§fn rewind(&mut self) -> Result<(), Error>
fn rewind(&mut self) -> Result<(), Error>
Rewind to the beginning of a stream. Read more
source§impl Stream for StoredFileData
impl Stream for StoredFileData
§type Item = Result<DataContent, AppError>
type Item = Result<DataContent, AppError>
Values yielded by the stream.
Auto Trait Implementations§
impl RefUnwindSafe for StoredFileData
impl Send for StoredFileData
impl Sync for StoredFileData
impl Unpin for StoredFileData
impl UnwindSafe for StoredFileData
Blanket Implementations§
source§impl<R> AsyncReadExt for Rwhere
R: AsyncRead + ?Sized,
impl<R> AsyncReadExt for Rwhere R: AsyncRead + ?Sized,
source§fn chain<R>(self, next: R) -> Chain<Self, R>where
Self: Sized,
R: AsyncRead,
fn chain<R>(self, next: R) -> Chain<Self, R>where Self: Sized, R: AsyncRead,
Creates an adaptor which will chain this stream with another. Read more
source§fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>where
Self: Unpin,
fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>where Self: Unpin,
Tries to read some bytes directly into the given
buf in asynchronous
manner, returning a future type. Read moresource§fn read_vectored<'a>(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self>where
Self: Unpin,
fn read_vectored<'a>( &'a mut self, bufs: &'a mut [IoSliceMut<'a>] ) -> ReadVectored<'a, Self>where Self: Unpin,
Creates a future which will read from the
AsyncRead into bufs using vectored
IO operations. Read moresource§fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self>where
Self: Unpin,
fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self>where Self: Unpin,
Creates a future which will read exactly enough bytes to fill
buf,
returning an error if end of file (EOF) is hit sooner. Read moresource§fn read_to_end<'a>(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEnd<'a, Self>where
Self: Unpin,
fn read_to_end<'a>( &'a mut self, buf: &'a mut Vec<u8, Global> ) -> ReadToEnd<'a, Self>where Self: Unpin,
Creates a future which will read all the bytes from this
AsyncRead. Read moresource§fn read_to_string<'a>(
&'a mut self,
buf: &'a mut String
) -> ReadToString<'a, Self>where
Self: Unpin,
fn read_to_string<'a>( &'a mut self, buf: &'a mut String ) -> ReadToString<'a, Self>where Self: Unpin,
Creates a future which will read all the bytes from this
AsyncRead. Read moresource§impl<R> AsyncReadExt for Rwhere
R: AsyncRead + ?Sized,
impl<R> AsyncReadExt for Rwhere R: AsyncRead + ?Sized,
source§fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>where
Self: Unpin,
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<B, 'a>(&'a mut self, buf: &'a mut B) -> ReadBuf<'a, Self, B>where
Self: Sized + Unpin,
B: BufMut,
fn read_buf<B, 'a>(&'a mut self, buf: &'a mut B) -> ReadBuf<'a, Self, B>where Self: Sized + Unpin, B: BufMut,
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,
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 moresource§fn read_u8<'a>(&'a mut self) -> ReadU8<&'a mut Self>where
Self: Unpin,
fn read_u8<'a>(&'a mut self) -> ReadU8<&'a mut Self>where Self: Unpin,
Reads an unsigned 8 bit integer from the underlying reader. Read more
source§fn read_i8<'a>(&'a mut self) -> ReadI8<&'a mut Self>where
Self: Unpin,
fn read_i8<'a>(&'a mut self) -> ReadI8<&'a mut Self>where Self: Unpin,
Reads a signed 8 bit integer from the underlying reader. Read more
source§fn read_u16<'a>(&'a mut self) -> ReadU16<&'a mut Self>where
Self: Unpin,
fn read_u16<'a>(&'a mut self) -> ReadU16<&'a 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<'a>(&'a mut self) -> ReadI16<&'a mut Self>where
Self: Unpin,
fn read_i16<'a>(&'a mut self) -> ReadI16<&'a 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<'a>(&'a mut self) -> ReadU32<&'a mut Self>where
Self: Unpin,
fn read_u32<'a>(&'a mut self) -> ReadU32<&'a 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<'a>(&'a mut self) -> ReadI32<&'a mut Self>where
Self: Unpin,
fn read_i32<'a>(&'a mut self) -> ReadI32<&'a 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<'a>(&'a mut self) -> ReadU64<&'a mut Self>where
Self: Unpin,
fn read_u64<'a>(&'a mut self) -> ReadU64<&'a 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<'a>(&'a mut self) -> ReadI64<&'a mut Self>where
Self: Unpin,
fn read_i64<'a>(&'a mut self) -> ReadI64<&'a 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<'a>(&'a mut self) -> ReadU128<&'a mut Self>where
Self: Unpin,
fn read_u128<'a>(&'a mut self) -> ReadU128<&'a 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<'a>(&'a mut self) -> ReadI128<&'a mut Self>where
Self: Unpin,
fn read_i128<'a>(&'a mut self) -> ReadI128<&'a 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<'a>(&'a mut self) -> ReadF32<&'a mut Self>where
Self: Unpin,
fn read_f32<'a>(&'a mut self) -> ReadF32<&'a 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<'a>(&'a mut self) -> ReadF64<&'a mut Self>where
Self: Unpin,
fn read_f64<'a>(&'a mut self) -> ReadF64<&'a 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<'a>(&'a mut self) -> ReadU16Le<&'a mut Self>where
Self: Unpin,
fn read_u16_le<'a>(&'a mut self) -> ReadU16Le<&'a 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<'a>(&'a mut self) -> ReadI16Le<&'a mut Self>where
Self: Unpin,
fn read_i16_le<'a>(&'a mut self) -> ReadI16Le<&'a 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<'a>(&'a mut self) -> ReadU32Le<&'a mut Self>where
Self: Unpin,
fn read_u32_le<'a>(&'a mut self) -> ReadU32Le<&'a 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<'a>(&'a mut self) -> ReadI32Le<&'a mut Self>where
Self: Unpin,
fn read_i32_le<'a>(&'a mut self) -> ReadI32Le<&'a 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<'a>(&'a mut self) -> ReadU64Le<&'a mut Self>where
Self: Unpin,
fn read_u64_le<'a>(&'a mut self) -> ReadU64Le<&'a 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<'a>(&'a mut self) -> ReadI64Le<&'a mut Self>where
Self: Unpin,
fn read_i64_le<'a>(&'a mut self) -> ReadI64Le<&'a 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<'a>(&'a mut self) -> ReadU128Le<&'a mut Self>where
Self: Unpin,
fn read_u128_le<'a>(&'a mut self) -> ReadU128Le<&'a 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<'a>(&'a mut self) -> ReadI128Le<&'a mut Self>where
Self: Unpin,
fn read_i128_le<'a>(&'a mut self) -> ReadI128Le<&'a 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<'a>(&'a mut self) -> ReadF32Le<&'a mut Self>where
Self: Unpin,
fn read_f32_le<'a>(&'a mut self) -> ReadF32Le<&'a 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<'a>(&'a mut self) -> ReadF64Le<&'a mut Self>where
Self: Unpin,
fn read_f64_le<'a>(&'a mut self) -> ReadF64Le<&'a 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, Global>
) -> ReadToEnd<'a, Self>where
Self: Unpin,
fn read_to_end<'a>( &'a mut self, buf: &'a mut Vec<u8, Global> ) -> ReadToEnd<'a, Self>where Self: Unpin,
Reads all bytes until EOF in this source, placing them into
buf. Read moresource§impl<S> AsyncSeekExt for Swhere
S: AsyncSeek + ?Sized,
impl<S> AsyncSeekExt for Swhere S: AsyncSeek + ?Sized,
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
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where &'a Self: for<'a> IntoIterator,
Formats each item in a sequence. Read more
§impl<T> FuturesAsyncReadCompatExt for Twhere
T: AsyncRead,
impl<T> FuturesAsyncReadCompatExt for Twhere T: AsyncRead,
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Requestsource§impl<T> IntoStreamingRequest for Twhere
T: Stream + Send + 'static,
impl<T> IntoStreamingRequest for Twhere T: Stream + Send + 'static,
§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere R: 'a,
Borrows
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere
Self: Borrow<B>,
B: 'a + ?Sized,
R: 'a,
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere Self: Borrow<B>, B: 'a + ?Sized, R: 'a,
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> Rwhere
Self: BorrowMut<B>,
B: 'a + ?Sized,
R: 'a,
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> Rwhere Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere
Self: AsRef<U>,
U: 'a + ?Sized,
R: 'a,
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere Self: AsRef<U>, U: 'a + ?Sized, R: 'a,
Borrows
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> Rwhere
Self: AsMut<U>,
U: 'a + ?Sized,
R: 'a,
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> Rwhere Self: AsMut<U>, U: 'a + ?Sized, R: 'a,
Mutably borrows
self, then passes self.as_mut() into the pipe
function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<R> ReadBytesExt for Rwhere
R: Read + ?Sized,
impl<R> ReadBytesExt for Rwhere R: Read + ?Sized,
§fn read_u8(&mut self) -> Result<u8, Error>
fn read_u8(&mut self) -> Result<u8, Error>
Reads an unsigned 8 bit integer from the underlying reader. Read more
§fn read_i8(&mut self) -> Result<i8, Error>
fn read_i8(&mut self) -> Result<i8, Error>
Reads a signed 8 bit integer from the underlying reader. Read more
§fn read_u16<T>(&mut self) -> Result<u16, Error>where
T: ByteOrder,
fn read_u16<T>(&mut self) -> Result<u16, Error>where T: ByteOrder,
Reads an unsigned 16 bit integer from the underlying reader. Read more
§fn read_i16<T>(&mut self) -> Result<i16, Error>where
T: ByteOrder,
fn read_i16<T>(&mut self) -> Result<i16, Error>where T: ByteOrder,
Reads a signed 16 bit integer from the underlying reader. Read more
§fn read_u24<T>(&mut self) -> Result<u32, Error>where
T: ByteOrder,
fn read_u24<T>(&mut self) -> Result<u32, Error>where T: ByteOrder,
Reads an unsigned 24 bit integer from the underlying reader. Read more
§fn read_i24<T>(&mut self) -> Result<i32, Error>where
T: ByteOrder,
fn read_i24<T>(&mut self) -> Result<i32, Error>where T: ByteOrder,
Reads a signed 24 bit integer from the underlying reader. Read more
§fn read_u32<T>(&mut self) -> Result<u32, Error>where
T: ByteOrder,
fn read_u32<T>(&mut self) -> Result<u32, Error>where T: ByteOrder,
Reads an unsigned 32 bit integer from the underlying reader. Read more
§fn read_i32<T>(&mut self) -> Result<i32, Error>where
T: ByteOrder,
fn read_i32<T>(&mut self) -> Result<i32, Error>where T: ByteOrder,
Reads a signed 32 bit integer from the underlying reader. Read more
§fn read_u48<T>(&mut self) -> Result<u64, Error>where
T: ByteOrder,
fn read_u48<T>(&mut self) -> Result<u64, Error>where T: ByteOrder,
Reads an unsigned 48 bit integer from the underlying reader. Read more
§fn read_i48<T>(&mut self) -> Result<i64, Error>where
T: ByteOrder,
fn read_i48<T>(&mut self) -> Result<i64, Error>where T: ByteOrder,
Reads a signed 48 bit integer from the underlying reader. Read more
§fn read_u64<T>(&mut self) -> Result<u64, Error>where
T: ByteOrder,
fn read_u64<T>(&mut self) -> Result<u64, Error>where T: ByteOrder,
Reads an unsigned 64 bit integer from the underlying reader. Read more
§fn read_i64<T>(&mut self) -> Result<i64, Error>where
T: ByteOrder,
fn read_i64<T>(&mut self) -> Result<i64, Error>where T: ByteOrder,
Reads a signed 64 bit integer from the underlying reader. Read more
§fn read_u128<T>(&mut self) -> Result<u128, Error>where
T: ByteOrder,
fn read_u128<T>(&mut self) -> Result<u128, Error>where T: ByteOrder,
Reads an unsigned 128 bit integer from the underlying reader. Read more
§fn read_i128<T>(&mut self) -> Result<i128, Error>where
T: ByteOrder,
fn read_i128<T>(&mut self) -> Result<i128, Error>where T: ByteOrder,
Reads a signed 128 bit integer from the underlying reader. Read more
§fn read_uint<T>(&mut self, nbytes: usize) -> Result<u64, Error>where
T: ByteOrder,
fn read_uint<T>(&mut self, nbytes: usize) -> Result<u64, Error>where T: ByteOrder,
Reads an unsigned n-bytes integer from the underlying reader. Read more
§fn read_int<T>(&mut self, nbytes: usize) -> Result<i64, Error>where
T: ByteOrder,
fn read_int<T>(&mut self, nbytes: usize) -> Result<i64, Error>where T: ByteOrder,
Reads a signed n-bytes integer from the underlying reader. Read more
§fn read_uint128<T>(&mut self, nbytes: usize) -> Result<u128, Error>where
T: ByteOrder,
fn read_uint128<T>(&mut self, nbytes: usize) -> Result<u128, Error>where T: ByteOrder,
Reads an unsigned n-bytes integer from the underlying reader.
§fn read_int128<T>(&mut self, nbytes: usize) -> Result<i128, Error>where
T: ByteOrder,
fn read_int128<T>(&mut self, nbytes: usize) -> Result<i128, Error>where T: ByteOrder,
Reads a signed n-bytes integer from the underlying reader.
§fn read_f32<T>(&mut self) -> Result<f32, Error>where
T: ByteOrder,
fn read_f32<T>(&mut self) -> Result<f32, Error>where T: ByteOrder,
Reads a IEEE754 single-precision (4 bytes) floating point number from
the underlying reader. Read more
§fn read_f64<T>(&mut self) -> Result<f64, Error>where
T: ByteOrder,
fn read_f64<T>(&mut self) -> Result<f64, Error>where T: ByteOrder,
Reads a IEEE754 double-precision (8 bytes) floating point number from
the underlying reader. Read more
§fn read_u16_into<T>(&mut self, dst: &mut [u16]) -> Result<(), Error>where
T: ByteOrder,
fn read_u16_into<T>(&mut self, dst: &mut [u16]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of unsigned 16 bit integers from the underlying
reader. Read more
§fn read_u32_into<T>(&mut self, dst: &mut [u32]) -> Result<(), Error>where
T: ByteOrder,
fn read_u32_into<T>(&mut self, dst: &mut [u32]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of unsigned 32 bit integers from the underlying
reader. Read more
§fn read_u64_into<T>(&mut self, dst: &mut [u64]) -> Result<(), Error>where
T: ByteOrder,
fn read_u64_into<T>(&mut self, dst: &mut [u64]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of unsigned 64 bit integers from the underlying
reader. Read more
§fn read_u128_into<T>(&mut self, dst: &mut [u128]) -> Result<(), Error>where
T: ByteOrder,
fn read_u128_into<T>(&mut self, dst: &mut [u128]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of unsigned 128 bit integers from the underlying
reader. Read more
§fn read_i8_into(&mut self, dst: &mut [i8]) -> Result<(), Error>
fn read_i8_into(&mut self, dst: &mut [i8]) -> Result<(), Error>
Reads a sequence of signed 8 bit integers from the underlying reader. Read more
§fn read_i16_into<T>(&mut self, dst: &mut [i16]) -> Result<(), Error>where
T: ByteOrder,
fn read_i16_into<T>(&mut self, dst: &mut [i16]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of signed 16 bit integers from the underlying
reader. Read more
§fn read_i32_into<T>(&mut self, dst: &mut [i32]) -> Result<(), Error>where
T: ByteOrder,
fn read_i32_into<T>(&mut self, dst: &mut [i32]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of signed 32 bit integers from the underlying
reader. Read more
§fn read_i64_into<T>(&mut self, dst: &mut [i64]) -> Result<(), Error>where
T: ByteOrder,
fn read_i64_into<T>(&mut self, dst: &mut [i64]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of signed 64 bit integers from the underlying
reader. Read more
§fn read_i128_into<T>(&mut self, dst: &mut [i128]) -> Result<(), Error>where
T: ByteOrder,
fn read_i128_into<T>(&mut self, dst: &mut [i128]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of signed 128 bit integers from the underlying
reader. Read more
§fn read_f32_into<T>(&mut self, dst: &mut [f32]) -> Result<(), Error>where
T: ByteOrder,
fn read_f32_into<T>(&mut self, dst: &mut [f32]) -> Result<(), Error>where T: ByteOrder,
Reads a sequence of IEEE754 single-precision (4 bytes) floating
point numbers from the underlying reader. Read more
§fn read_f32_into_unchecked<T>(&mut self, dst: &mut [f32]) -> Result<(), Error>where
T: ByteOrder,
fn read_f32_into_unchecked<T>(&mut self, dst: &mut [f32]) -> Result<(), Error>where T: ByteOrder,
👎Deprecated since 1.2.0: please use
read_f32_into insteadDEPRECATED. Read more
source§impl<R> ReadEndian<[f32]> for Rwhere
R: Read,
impl<R> ReadEndian<[f32]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [f32]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [f32] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [f32]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [f32]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[f64]> for Rwhere
R: Read,
impl<R> ReadEndian<[f64]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [f64]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [f64] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [f64]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [f64]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[i128]> for Rwhere
R: Read,
impl<R> ReadEndian<[i128]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [i128]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [i128] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [i128]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [i128]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[i16]> for Rwhere
R: Read,
impl<R> ReadEndian<[i16]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [i16]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [i16] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [i16]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [i16]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[i32]> for Rwhere
R: Read,
impl<R> ReadEndian<[i32]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [i32]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [i32] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [i32]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [i32]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[i64]> for Rwhere
R: Read,
impl<R> ReadEndian<[i64]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [i64]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [i64] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [i64]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [i64]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[i8]> for Rwhere
R: Read,
impl<R> ReadEndian<[i8]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [i8]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [i8] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [i8]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [i8]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[u128]> for Rwhere
R: Read,
impl<R> ReadEndian<[u128]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [u128]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [u128] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [u128]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [u128]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[u16]> for Rwhere
R: Read,
impl<R> ReadEndian<[u16]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [u16]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [u16] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [u16]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [u16]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[u32]> for Rwhere
R: Read,
impl<R> ReadEndian<[u32]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [u32]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [u32] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [u32]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [u32]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[u64]> for Rwhere
R: Read,
impl<R> ReadEndian<[u64]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [u64]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [u64] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [u64]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [u64]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<[u8]> for Rwhere
R: Read,
impl<R> ReadEndian<[u8]> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut [u8]
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut [u8] ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut [u8]) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut [u8]) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<f32> for Rwhere
R: Read,
impl<R> ReadEndian<f32> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut f32) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut f32) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut f32) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut f32) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<f64> for Rwhere
R: Read,
impl<R> ReadEndian<f64> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut f64) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut f64) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut f64) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut f64) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<i128> for Rwhere
R: Read,
impl<R> ReadEndian<i128> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut i128
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut i128 ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut i128) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut i128) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<i16> for Rwhere
R: Read,
impl<R> ReadEndian<i16> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut i16) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut i16) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut i16) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut i16) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<i32> for Rwhere
R: Read,
impl<R> ReadEndian<i32> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut i32) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut i32) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut i32) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut i32) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<i64> for Rwhere
R: Read,
impl<R> ReadEndian<i64> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut i64) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut i64) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut i64) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut i64) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<i8> for Rwhere
R: Read,
impl<R> ReadEndian<i8> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut i8) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut i8) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut i8) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut i8) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<u128> for Rwhere
R: Read,
impl<R> ReadEndian<u128> for Rwhere R: Read,
source§fn read_from_little_endian_into(
&mut self,
value: &mut u128
) -> Result<(), Error>
fn read_from_little_endian_into( &mut self, value: &mut u128 ) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut u128) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut u128) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<u16> for Rwhere
R: Read,
impl<R> ReadEndian<u16> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut u16) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut u16) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut u16) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut u16) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<u32> for Rwhere
R: Read,
impl<R> ReadEndian<u32> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut u32) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut u32) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut u32) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut u32) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<u64> for Rwhere
R: Read,
impl<R> ReadEndian<u64> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut u64) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut u64) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut u64) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut u64) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<R> ReadEndian<u8> for Rwhere
R: Read,
impl<R> ReadEndian<u8> for Rwhere R: Read,
source§fn read_from_little_endian_into(&mut self, value: &mut u8) -> Result<(), Error>
fn read_from_little_endian_into(&mut self, value: &mut u8) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_big_endian_into(&mut self, value: &mut u8) -> Result<(), Error>
fn read_from_big_endian_into(&mut self, value: &mut u8) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
fn read_from_native_endian_into(&mut self, value: &mut T) -> Result<(), Error>
Read into the supplied reference. Acts the same as
std::io::Read::read_exact.source§fn read_from_little_endian(&mut self) -> Result<T, Error>where
T: Default,
fn read_from_little_endian(&mut self) -> Result<T, Error>where T: Default,
Read the byte value of the inferred type
source§impl<T> StreamExt for Twhere
T: Stream + ?Sized,
impl<T> StreamExt for Twhere T: Stream + ?Sized,
source§fn next(&mut self) -> Next<'_, Self>where
Self: Unpin,
fn next(&mut self) -> Next<'_, Self>where Self: Unpin,
Creates a future that resolves to the next item in the stream. Read more
source§fn into_future(self) -> StreamFuture<Self>where
Self: Sized + Unpin,
fn into_future(self) -> StreamFuture<Self>where Self: Sized + Unpin,
source§fn map<T, F>(self, f: F) -> Map<Self, F>where
F: FnMut(Self::Item) -> T,
Self: Sized,
fn map<T, F>(self, f: F) -> Map<Self, F>where F: FnMut(Self::Item) -> T, Self: Sized,
Maps this stream’s items to a different type, returning a new stream of
the resulting type. Read more
source§fn enumerate(self) -> Enumerate<Self>where
Self: Sized,
fn enumerate(self) -> Enumerate<Self>where Self: Sized,
Creates a stream which gives the current iteration count as well as
the next value. Read more
source§fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F>where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized,
fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F>where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,
Filters the values produced by this stream according to the provided
asynchronous predicate. Read more
source§fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = Option<T>>,
Self: Sized,
fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = Option<T>>, Self: Sized,
Filters the values produced by this stream while simultaneously mapping
them to a different type according to the provided asynchronous closure. Read more
source§fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future,
Self: Sized,
fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future, Self: Sized,
Computes from this stream’s items new items of a different type using
an asynchronous closure. Read more
source§fn collect<C>(self) -> Collect<Self, C>where
C: Default + Extend<Self::Item>,
Self: Sized,
fn collect<C>(self) -> Collect<Self, C>where C: Default + Extend<Self::Item>, Self: Sized,
Transforms a stream into a collection, returning a
future representing the result of that computation. Read more
source§fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB>where
FromA: Default + Extend<A>,
FromB: Default + Extend<B>,
Self: Sized + Stream<Item = (A, B)>,
fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB>where FromA: Default + Extend<A>, FromB: Default + Extend<B>, Self: Sized + Stream<Item = (A, B)>,
Converts a stream of pairs into a future, which
resolves to pair of containers. Read more
source§fn concat(self) -> Concat<Self>where
Self: Sized,
Self::Item: Extend<<Self::Item as IntoIterator>::Item> + IntoIterator + Default,
fn concat(self) -> Concat<Self>where Self: Sized, Self::Item: Extend<<Self::Item as IntoIterator>::Item> + IntoIterator + Default,
Concatenate all items of a stream into a single extendable
destination, returning a future representing the end result. Read more
source§fn count(self) -> Count<Self>where
Self: Sized,
fn count(self) -> Count<Self>where Self: Sized,
Drives the stream to completion, counting the number of items. Read more
source§fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F>where
F: FnMut(T, Self::Item) -> Fut,
Fut: Future<Output = T>,
Self: Sized,
fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F>where F: FnMut(T, Self::Item) -> Fut, Fut: Future<Output = T>, Self: Sized,
Execute an accumulating asynchronous computation over a stream,
collecting all the values into one final result. Read more
source§fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized,
fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,
Execute predicate over asynchronous stream, and return
true if any element in stream satisfied a predicate. Read moresource§fn all<Fut, F>(self, f: F) -> All<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized,
fn all<Fut, F>(self, f: F) -> All<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,
Execute predicate over asynchronous stream, and return
true if all element in stream satisfied a predicate. Read moresource§fn flatten(self) -> Flatten<Self>where
Self::Item: Stream,
Self: Sized,
fn flatten(self) -> Flatten<Self>where Self::Item: Stream, Self: Sized,
Flattens a stream of streams into just one continuous stream. Read more
source§fn flatten_unordered(
self,
limit: impl Into<Option<usize>>
) -> FlattenUnorderedWithFlowController<Self, ()>where
Self::Item: Stream + Unpin,
Self: Sized,
fn flatten_unordered( self, limit: impl Into<Option<usize>> ) -> FlattenUnorderedWithFlowController<Self, ()>where Self::Item: Stream + Unpin, Self: Sized,
Flattens a stream of streams into just one continuous stream. Polls
inner streams produced by the base stream concurrently. Read more
source§fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F>where
F: FnMut(Self::Item) -> U,
U: Stream,
Self: Sized,
fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F>where F: FnMut(Self::Item) -> U, U: Stream, Self: Sized,
source§fn flat_map_unordered<U, F>(
self,
limit: impl Into<Option<usize>>,
f: F
) -> FlatMapUnordered<Self, U, F>where
U: Stream + Unpin,
F: FnMut(Self::Item) -> U,
Self: Sized,
fn flat_map_unordered<U, F>( self, limit: impl Into<Option<usize>>, f: F ) -> FlatMapUnordered<Self, U, F>where U: Stream + Unpin, F: FnMut(Self::Item) -> U, Self: Sized,
Maps a stream like
StreamExt::map but flattens nested Streams
and polls them concurrently, yielding items in any order, as they made
available. Read moresource§fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F>where
F: FnMut(&mut S, Self::Item) -> Fut,
Fut: Future<Output = Option<B>>,
Self: Sized,
fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F>where F: FnMut(&mut S, Self::Item) -> Fut, Fut: Future<Output = Option<B>>, Self: Sized,
Combinator similar to
StreamExt::fold that holds internal state
and produces a new stream. Read moresource§fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F>where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized,
fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F>where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,
Skip elements on this stream while the provided asynchronous predicate
resolves to
true. Read moresource§fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F>where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized,
fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F>where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>, Self: Sized,
Take elements from this stream while the provided asynchronous predicate
resolves to
true. Read moresource§fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut>where
Fut: Future,
Self: Sized,
fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut>where Fut: Future, Self: Sized,
Take elements from this stream until the provided future resolves. Read more
source§fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,
Self: Sized,
fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = ()>, Self: Sized,
Runs this stream to completion, executing the provided asynchronous
closure for each element on the stream. Read more
source§fn for_each_concurrent<Fut, F>(
self,
limit: impl Into<Option<usize>>,
f: F
) -> ForEachConcurrent<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,
Self: Sized,
fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F ) -> ForEachConcurrent<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = ()>, Self: Sized,
Runs this stream to completion, executing the provided asynchronous
closure for each element on the stream concurrently as elements become
available. Read more
source§fn take(self, n: usize) -> Take<Self>where
Self: Sized,
fn take(self, n: usize) -> Take<Self>where Self: Sized,
Creates a new stream of at most
n items of the underlying stream. Read moresource§fn skip(self, n: usize) -> Skip<Self>where
Self: Sized,
fn skip(self, n: usize) -> Skip<Self>where Self: Sized,
Creates a new stream which skips
n items of the underlying stream. Read moresource§fn catch_unwind(self) -> CatchUnwind<Self>where
Self: Sized + UnwindSafe,
fn catch_unwind(self) -> CatchUnwind<Self>where Self: Sized + UnwindSafe,
Catches unwinding panics while polling the stream. Read more
source§fn boxed<'a>(
self
) -> Pin<Box<dyn Stream<Item = Self::Item> + Send + 'a, Global>>where
Self: Sized + Send + 'a,
fn boxed<'a>( self ) -> Pin<Box<dyn Stream<Item = Self::Item> + Send + 'a, Global>>where Self: Sized + Send + 'a,
Wrap the stream in a Box, pinning it. Read more
source§fn boxed_local<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a, Global>>where
Self: Sized + 'a,
fn boxed_local<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a, Global>>where Self: Sized + 'a,
Wrap the stream in a Box, pinning it. Read more
source§fn buffered(self, n: usize) -> Buffered<Self>where
Self::Item: Future,
Self: Sized,
fn buffered(self, n: usize) -> Buffered<Self>where Self::Item: Future, Self: Sized,
An adaptor for creating a buffered list of pending futures. Read more
source§fn buffer_unordered(self, n: usize) -> BufferUnordered<Self>where
Self::Item: Future,
Self: Sized,
fn buffer_unordered(self, n: usize) -> BufferUnordered<Self>where Self::Item: Future, Self: Sized,
An adaptor for creating a buffered list of pending futures (unordered). Read more
source§fn zip<St>(self, other: St) -> Zip<Self, St>where
St: Stream,
Self: Sized,
fn zip<St>(self, other: St) -> Zip<Self, St>where St: Stream, Self: Sized,
An adapter for zipping two streams together. Read more
source§fn chain<St>(self, other: St) -> Chain<Self, St>where
St: Stream<Item = Self::Item>,
Self: Sized,
fn chain<St>(self, other: St) -> Chain<Self, St>where St: Stream<Item = Self::Item>, Self: Sized,
Adapter for chaining two streams. Read more
source§fn peekable(self) -> Peekable<Self>where
Self: Sized,
fn peekable(self) -> Peekable<Self>where Self: Sized,
Creates a new stream which exposes a
peek method. Read moresource§fn chunks(self, capacity: usize) -> Chunks<Self>where
Self: Sized,
fn chunks(self, capacity: usize) -> Chunks<Self>where Self: Sized,
An adaptor for chunking up items of the stream inside a vector. Read more
source§fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>where
Self: Sized,
fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>where Self: Sized,
An adaptor for chunking up ready items of the stream inside a vector. Read more
source§fn forward<S>(self, sink: S) -> Forward<Self, S>where
S: Sink<Self::Ok, Error = Self::Error>,
Self: TryStream + Sized,
fn forward<S>(self, sink: S) -> Forward<Self, S>where S: Sink<Self::Ok, Error = Self::Error>, Self: TryStream + Sized,
A future that completes after the given stream has been fully processed
into the sink and the sink has been flushed and closed. Read more
source§fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>)where
Self: Sink<Item> + Sized,
fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>)where Self: Sink<Item> + Sized,
source§fn inspect<F>(self, f: F) -> Inspect<Self, F>where
F: FnMut(&Self::Item),
Self: Sized,
fn inspect<F>(self, f: F) -> Inspect<Self, F>where F: FnMut(&Self::Item), Self: Sized,
Do something with each item of this stream, afterwards passing it on. Read more
source§fn left_stream<B>(self) -> Either<Self, B>where
B: Stream<Item = Self::Item>,
Self: Sized,
fn left_stream<B>(self) -> Either<Self, B>where B: Stream<Item = Self::Item>, Self: Sized,
source§fn right_stream<B>(self) -> Either<B, Self>where
B: Stream<Item = Self::Item>,
Self: Sized,
fn right_stream<B>(self) -> Either<B, Self>where B: Stream<Item = Self::Item>, Self: Sized,
source§fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>where
Self: Unpin,
fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>where Self: Unpin,
A convenience method for calling [
Stream::poll_next] on Unpin
stream types.source§fn select_next_some(&mut self) -> SelectNextSome<'_, Self>where
Self: Unpin + FusedStream,
fn select_next_some(&mut self) -> SelectNextSome<'_, Self>where Self: Unpin + FusedStream,
§impl<St> StreamExt for Stwhere
St: Stream + ?Sized,
impl<St> StreamExt for Stwhere St: Stream + ?Sized,
§fn next(&mut self) -> Next<'_, Self>where
Self: Unpin,
fn next(&mut self) -> Next<'_, Self>where Self: Unpin,
Consumes and returns the next value in the stream or
None if the
stream is finished. Read more§fn try_next<T, E>(&mut self) -> TryNext<'_, Self>where
Self: Stream<Item = Result<T, E>> + Unpin,
fn try_next<T, E>(&mut self) -> TryNext<'_, Self>where Self: Stream<Item = Result<T, E>> + Unpin,
Consumes and returns the next item in the stream. If an error is
encountered before the next item, the error is returned instead. Read more
§fn map<T, F>(self, f: F) -> Map<Self, F>where
F: FnMut(Self::Item) -> T,
Self: Sized,
fn map<T, F>(self, f: F) -> Map<Self, F>where F: FnMut(Self::Item) -> T, Self: Sized,
Maps this stream’s items to a different type, returning a new stream of
the resulting type. Read more
§fn map_while<T, F>(self, f: F) -> MapWhile<Self, F>where
F: FnMut(Self::Item) -> Option<T>,
Self: Sized,
fn map_while<T, F>(self, f: F) -> MapWhile<Self, F>where F: FnMut(Self::Item) -> Option<T>, Self: Sized,
Map this stream’s items to a different type for as long as determined by
the provided closure. A stream of the target type will be returned,
which will yield elements until the closure returns
None. Read more§fn then<F, Fut>(self, f: F) -> Then<Self, Fut, F>where
F: FnMut(Self::Item) -> Fut,
Fut: Future,
Self: Sized,
fn then<F, Fut>(self, f: F) -> Then<Self, Fut, F>where F: FnMut(Self::Item) -> Fut, Fut: Future, Self: Sized,
Maps this stream’s items asynchronously to a different type, returning a
new stream of the resulting type. Read more
§fn merge<U>(self, other: U) -> Merge<Self, U>where
U: Stream<Item = Self::Item>,
Self: Sized,
fn merge<U>(self, other: U) -> Merge<Self, U>where U: Stream<Item = Self::Item>, Self: Sized,
Combine two streams into one by interleaving the output of both as it
is produced. Read more
§fn filter<F>(self, f: F) -> Filter<Self, F>where
F: FnMut(&Self::Item) -> bool,
Self: Sized,
fn filter<F>(self, f: F) -> Filter<Self, F>where F: FnMut(&Self::Item) -> bool, Self: Sized,
Filters the values produced by this stream according to the provided
predicate. Read more
§fn filter_map<T, F>(self, f: F) -> FilterMap<Self, F>where
F: FnMut(Self::Item) -> Option<T>,
Self: Sized,
fn filter_map<T, F>(self, f: F) -> FilterMap<Self, F>where F: FnMut(Self::Item) -> Option<T>, Self: Sized,
Filters the values produced by this stream while simultaneously mapping
them to a different type according to the provided closure. Read more
§fn fuse(self) -> Fuse<Self>where
Self: Sized,
fn fuse(self) -> Fuse<Self>where Self: Sized,
Creates a stream which ends after the first
None. Read more§fn take(self, n: usize) -> Take<Self>where
Self: Sized,
fn take(self, n: usize) -> Take<Self>where Self: Sized,
Creates a new stream of at most
n items of the underlying stream. Read more§fn take_while<F>(self, f: F) -> TakeWhile<Self, F>where
F: FnMut(&Self::Item) -> bool,
Self: Sized,
fn take_while<F>(self, f: F) -> TakeWhile<Self, F>where F: FnMut(&Self::Item) -> bool, Self: Sized,
Take elements from this stream while the provided predicate
resolves to
true. Read more§fn skip(self, n: usize) -> Skip<Self>where
Self: Sized,
fn skip(self, n: usize) -> Skip<Self>where Self: Sized,
Creates a new stream that will skip the
n first items of the
underlying stream. Read more§fn skip_while<F>(self, f: F) -> SkipWhile<Self, F>where
F: FnMut(&Self::Item) -> bool,
Self: Sized,
fn skip_while<F>(self, f: F) -> SkipWhile<Self, F>where F: FnMut(&Self::Item) -> bool, Self: Sized,
Skip elements from the underlying stream while the provided predicate
resolves to
true. Read more§fn all<F>(&mut self, f: F) -> AllFuture<'_, Self, F>where
Self: Unpin,
F: FnMut(Self::Item) -> bool,
fn all<F>(&mut self, f: F) -> AllFuture<'_, Self, F>where Self: Unpin, F: FnMut(Self::Item) -> bool,
Tests if every element of the stream matches a predicate. Read more
§fn any<F>(&mut self, f: F) -> AnyFuture<'_, Self, F>where
Self: Unpin,
F: FnMut(Self::Item) -> bool,
fn any<F>(&mut self, f: F) -> AnyFuture<'_, Self, F>where Self: Unpin, F: FnMut(Self::Item) -> bool,
Tests if any element of the stream matches a predicate. Read more
§fn chain<U>(self, other: U) -> Chain<Self, U>where
U: Stream<Item = Self::Item>,
Self: Sized,
fn chain<U>(self, other: U) -> Chain<Self, U>where U: Stream<Item = Self::Item>, Self: Sized,
Combine two streams into one by first returning all values from the
first stream then all values from the second stream. Read more
§fn fold<B, F>(self, init: B, f: F) -> FoldFuture<Self, B, F>where
Self: Sized,
F: FnMut(B, Self::Item) -> B,
fn fold<B, F>(self, init: B, f: F) -> FoldFuture<Self, B, F>where Self: Sized, F: FnMut(B, Self::Item) -> B,
A combinator that applies a function to every element in a stream
producing a single, final value. Read more
§fn collect<T>(self) -> Collect<Self, T>where
T: FromStream<Self::Item>,
Self: Sized,
fn collect<T>(self) -> Collect<Self, T>where T: FromStream<Self::Item>, Self: Sized,
Drain stream pushing all emitted values into a collection. Read more
§fn timeout(self, duration: Duration) -> Timeout<Self>where
Self: Sized,
fn timeout(self, duration: Duration) -> Timeout<Self>where Self: Sized,
Applies a per-item timeout to the passed stream. Read more
§fn timeout_repeating(self, interval: Interval) -> TimeoutRepeating<Self>where
Self: Sized,
fn timeout_repeating(self, interval: Interval) -> TimeoutRepeating<Self>where Self: Sized,
Applies a per-item timeout to the passed stream. Read more
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Selfwhere
Self: Borrow<B>,
B: ?Sized,
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Selfwhere Self: Borrow<B>, B: ?Sized,
Immutable access to the
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere
Self: BorrowMut<B>,
B: ?Sized,
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere Self: BorrowMut<B>, B: ?Sized,
Mutable access to the
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Selfwhere
Self: AsRef<R>,
R: ?Sized,
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Selfwhere Self: AsRef<R>, R: ?Sized,
Immutable access to the
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere
Self: AsMut<R>,
R: ?Sized,
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere Self: AsMut<R>, R: ?Sized,
Mutable access to the
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Selfwhere
Self: Deref<Target = T>,
T: ?Sized,
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Selfwhere Self: Deref<Target = T>, T: ?Sized,
Immutable access to the
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Selfwhere
Self: DerefMut<Target = T> + Deref,
T: ?Sized,
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Selfwhere Self: DerefMut<Target = T> + Deref, T: ?Sized,
Mutable access to the
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Selfwhere
Self: Borrow<B>,
B: ?Sized,
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Selfwhere Self: Borrow<B>, B: ?Sized,
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere
Self: BorrowMut<B>,
B: ?Sized,
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere Self: BorrowMut<B>, B: ?Sized,
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Selfwhere
Self: AsRef<R>,
R: ?Sized,
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Selfwhere Self: AsRef<R>, R: ?Sized,
Calls
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere
Self: AsMut<R>,
R: ?Sized,
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere Self: AsMut<R>, R: ?Sized,
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.§impl<T> TryConv for T
impl<T> TryConv for T
source§impl<S> TryStreamExt for Swhere
S: TryStream + ?Sized,
impl<S> TryStreamExt for Swhere S: TryStream + ?Sized,
source§fn err_into<E>(self) -> ErrInto<Self, E>where
Self: Sized,
Self::Error: Into<E>,
fn err_into<E>(self) -> ErrInto<Self, E>where Self: Sized, Self::Error: Into<E>,
Wraps the current stream in a new stream which converts the error type
into the one provided. Read more
source§fn map_ok<T, F>(self, f: F) -> MapOk<Self, F>where
Self: Sized,
F: FnMut(Self::Ok) -> T,
fn map_ok<T, F>(self, f: F) -> MapOk<Self, F>where Self: Sized, F: FnMut(Self::Ok) -> T,
Wraps the current stream in a new stream which maps the success value
using the provided closure. Read more
source§fn map_err<E, F>(self, f: F) -> MapErr<Self, F>where
Self: Sized,
F: FnMut(Self::Error) -> E,
fn map_err<E, F>(self, f: F) -> MapErr<Self, F>where Self: Sized, F: FnMut(Self::Error) -> E,
Wraps the current stream in a new stream which maps the error value
using the provided closure. Read more
source§fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F>where
F: FnMut(Self::Ok) -> Fut,
Fut: TryFuture<Error = Self::Error>,
Self: Sized,
fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F>where F: FnMut(Self::Ok) -> Fut, Fut: TryFuture<Error = Self::Error>, Self: Sized,
Chain on a computation for when a value is ready, passing the successful
results to the provided closure
f. Read moresource§fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F>where
F: FnMut(Self::Error) -> Fut,
Fut: TryFuture<Ok = Self::Ok>,
Self: Sized,
fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F>where F: FnMut(Self::Error) -> Fut, Fut: TryFuture<Ok = Self::Ok>, Self: Sized,
Chain on a computation for when an error happens, passing the
erroneous result to the provided closure
f. Read moresource§fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F>where
F: FnMut(&Self::Ok),
Self: Sized,
fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F>where F: FnMut(&Self::Ok), Self: Sized,
Do something with the success value of this stream, afterwards passing
it on. Read more
source§fn inspect_err<F>(self, f: F) -> InspectErr<Self, F>where
F: FnMut(&Self::Error),
Self: Sized,
fn inspect_err<F>(self, f: F) -> InspectErr<Self, F>where F: FnMut(&Self::Error), Self: Sized,
Do something with the error value of this stream, afterwards passing it on. Read more
source§fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
fn into_stream(self) -> IntoStream<Self>where Self: Sized,
source§fn try_next(&mut self) -> TryNext<'_, Self>where
Self: Unpin,
fn try_next(&mut self) -> TryNext<'_, Self>where Self: Unpin,
Creates a future that attempts to resolve the next item in the stream.
If an error is encountered before the next item, the error is returned
instead. Read more
source§fn try_for_each<Fut, F>(self, f: F) -> TryForEach<Self, Fut, F>where
F: FnMut(Self::Ok) -> Fut,
Fut: TryFuture<Ok = (), Error = Self::Error>,
Self: Sized,
fn try_for_each<Fut, F>(self, f: F) -> TryForEach<Self, Fut, F>where F: FnMut(Self::Ok) -> Fut, Fut: TryFuture<Ok = (), Error = Self::Error>, Self: Sized,
Attempts to run this stream to completion, executing the provided
asynchronous closure for each element on the stream. Read more
source§fn try_skip_while<Fut, F>(self, f: F) -> TrySkipWhile<Self, Fut, F>where
F: FnMut(&Self::Ok) -> Fut,
Fut: TryFuture<Ok = bool, Error = Self::Error>,
Self: Sized,
fn try_skip_while<Fut, F>(self, f: F) -> TrySkipWhile<Self, Fut, F>where F: FnMut(&Self::Ok) -> Fut, Fut: TryFuture<Ok = bool, Error = Self::Error>, Self: Sized,
Skip elements on this stream while the provided asynchronous predicate
resolves to
true. Read moresource§fn try_take_while<Fut, F>(self, f: F) -> TryTakeWhile<Self, Fut, F>where
F: FnMut(&Self::Ok) -> Fut,
Fut: TryFuture<Ok = bool, Error = Self::Error>,
Self: Sized,
fn try_take_while<Fut, F>(self, f: F) -> TryTakeWhile<Self, Fut, F>where F: FnMut(&Self::Ok) -> Fut, Fut: TryFuture<Ok = bool, Error = Self::Error>, Self: Sized,
Take elements on this stream while the provided asynchronous predicate
resolves to
true. Read moresource§fn try_for_each_concurrent<Fut, F>(
self,
limit: impl Into<Option<usize>>,
f: F
) -> TryForEachConcurrent<Self, Fut, F>where
F: FnMut(Self::Ok) -> Fut,
Fut: Future<Output = Result<(), Self::Error>>,
Self: Sized,
fn try_for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F ) -> TryForEachConcurrent<Self, Fut, F>where F: FnMut(Self::Ok) -> Fut, Fut: Future<Output = Result<(), Self::Error>>, Self: Sized,
Attempts to run this stream to completion, executing the provided asynchronous
closure for each element on the stream concurrently as elements become
available, exiting as soon as an error occurs. Read more
source§fn try_collect<C>(self) -> TryCollect<Self, C>where
C: Default + Extend<Self::Ok>,
Self: Sized,
fn try_collect<C>(self) -> TryCollect<Self, C>where C: Default + Extend<Self::Ok>, Self: Sized,
Attempt to transform a stream into a collection,
returning a future representing the result of that computation. Read more
source§fn try_chunks(self, capacity: usize) -> TryChunks<Self>where
Self: Sized,
fn try_chunks(self, capacity: usize) -> TryChunks<Self>where Self: Sized,
An adaptor for chunking up successful items of the stream inside a vector. Read more
source§fn try_filter<Fut, F>(self, f: F) -> TryFilter<Self, Fut, F>where
Fut: Future<Output = bool>,
F: FnMut(&Self::Ok) -> Fut,
Self: Sized,
fn try_filter<Fut, F>(self, f: F) -> TryFilter<Self, Fut, F>where Fut: Future<Output = bool>, F: FnMut(&Self::Ok) -> Fut, Self: Sized,
Attempt to filter the values produced by this stream according to the
provided asynchronous closure. Read more
source§fn try_filter_map<Fut, F, T>(self, f: F) -> TryFilterMap<Self, Fut, F>where
Fut: TryFuture<Ok = Option<T>, Error = Self::Error>,
F: FnMut(Self::Ok) -> Fut,
Self: Sized,
fn try_filter_map<Fut, F, T>(self, f: F) -> TryFilterMap<Self, Fut, F>where Fut: TryFuture<Ok = Option<T>, Error = Self::Error>, F: FnMut(Self::Ok) -> Fut, Self: Sized,
Attempt to filter the values produced by this stream while
simultaneously mapping them to a different type according to the
provided asynchronous closure. Read more
source§fn try_flatten_unordered(
self,
limit: impl Into<Option<usize>>
) -> TryFlattenUnordered<Self>where
Self::Ok: TryStream + Unpin,
<Self::Ok as TryStream>::Error: From<Self::Error>,
Self: Sized,
fn try_flatten_unordered( self, limit: impl Into<Option<usize>> ) -> TryFlattenUnordered<Self>where Self::Ok: TryStream + Unpin, <Self::Ok as TryStream>::Error: From<Self::Error>, Self: Sized,
Flattens a stream of streams into just one continuous stream. Produced streams
will be polled concurrently and any errors will be passed through without looking at them.
If the underlying base stream returns an error, it will be immediately propagated. Read more
source§fn try_flatten(self) -> TryFlatten<Self>where
Self::Ok: TryStream,
<Self::Ok as TryStream>::Error: From<Self::Error>,
Self: Sized,
fn try_flatten(self) -> TryFlatten<Self>where Self::Ok: TryStream, <Self::Ok as TryStream>::Error: From<Self::Error>, Self: Sized,
Flattens a stream of streams into just one continuous stream. Read more
source§fn try_fold<T, Fut, F>(self, init: T, f: F) -> TryFold<Self, Fut, T, F>where
F: FnMut(T, Self::Ok) -> Fut,
Fut: TryFuture<Ok = T, Error = Self::Error>,
Self: Sized,
fn try_fold<T, Fut, F>(self, init: T, f: F) -> TryFold<Self, Fut, T, F>where F: FnMut(T, Self::Ok) -> Fut, Fut: TryFuture<Ok = T, Error = Self::Error>, Self: Sized,
Attempt to execute an accumulating asynchronous computation over a
stream, collecting all the values into one final result. Read more
source§fn try_concat(self) -> TryConcat<Self>where
Self: Sized,
Self::Ok: Extend<<Self::Ok as IntoIterator>::Item> + IntoIterator + Default,
fn try_concat(self) -> TryConcat<Self>where Self: Sized, Self::Ok: Extend<<Self::Ok as IntoIterator>::Item> + IntoIterator + Default,
Attempt to concatenate all items of a stream into a single
extendable destination, returning a future representing the end result. Read more
source§fn try_buffer_unordered(self, n: usize) -> TryBufferUnordered<Self>where
Self::Ok: TryFuture<Error = Self::Error>,
Self: Sized,
fn try_buffer_unordered(self, n: usize) -> TryBufferUnordered<Self>where Self::Ok: TryFuture<Error = Self::Error>, Self: Sized,
Attempt to execute several futures from a stream concurrently (unordered). Read more
source§fn try_buffered(self, n: usize) -> TryBuffered<Self>where
Self::Ok: TryFuture<Error = Self::Error>,
Self: Sized,
fn try_buffered(self, n: usize) -> TryBuffered<Self>where Self::Ok: TryFuture<Error = Self::Error>, Self: Sized,
Attempt to execute several futures from a stream concurrently. Read more
source§fn try_poll_next_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Option<Result<Self::Ok, Self::Error>>>where
Self: Unpin,
fn try_poll_next_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Option<Result<Self::Ok, Self::Error>>>where Self: Unpin,
A convenience method for calling [
TryStream::try_poll_next] on Unpin
stream types.source§fn into_async_read(self) -> IntoAsyncRead<Self>where
Self: Sized + TryStreamExt<Error = Error>,
Self::Ok: AsRef<[u8]>,
fn into_async_read(self) -> IntoAsyncRead<Self>where Self: Sized + TryStreamExt<Error = Error>, Self::Ok: AsRef<[u8]>,
Adapter that converts this stream into an
AsyncBufRead. Read more