结构体 BufStream 

pub struct BufStream<RW> { /* private fields */ }

包装一个同时实现 AsyncWrite 和 AsyncRead 的类型，并对其输入和输出进行缓冲。

直接使用同时实现 AsyncWrite 和 AsyncRead 的类型可能效率很低。 例如，无论 write 多小都必须经过系统调用接口，每次读取也是如此。 BufWriter 和 BufReader 分别用来缓解这两个问题，但只能在一个方向上起作用。 BufStream 将其中一个包装在另一个之中，使两个方向都被缓冲。详情请参阅它们的文档。

实现

impl<RW: AsyncRead + AsyncWrite> BufStream<RW>

pub fn new(stream: RW) -> BufStream<RW>

将一个类型同时包装到 BufWriter 和 BufReader 中。

详情请参阅这些类型以及 BufStream 的文档。

pub fn with_capacity( reader_capacity: usize, writer_capacity: usize, stream: RW, ) -> BufStream<RW>

使用指定的 BufReader 容量和 BufWriter 容量创建一个 BufStream。

详情请参阅这些类型以及 BufStream 的文档。

pub fn get_ref(&self) -> &RW

获取底层 I/O 对象的引用。

不建议直接从底层 I/O 对象进行读取。

pub fn get_mut(&mut self) -> &mut RW

获取底层 I/O 对象的可变引用。

不建议直接从底层 I/O 对象进行读取。

pub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut RW>

获取底层 I/O 对象的固定可变引用。

不建议直接从底层 I/O 对象进行读取。

pub fn into_inner(self) -> RW

消耗此 BufStream，返回底层的 I/O 对象。

请注意内部缓冲区中的任何剩余数据都将丢失。

Trait 实现

impl<RW: AsyncRead + AsyncWrite> AsyncBufRead for BufStream<RW>

fn poll_fill_buf( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8]>>

Attempts to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty. 更多信息

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read. 更多信息

impl<RW: AsyncRead + AsyncWrite> AsyncRead for BufStream<RW>

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

Attempts to read from the AsyncRead into buf. 更多信息

impl<RW: AsyncRead + AsyncWrite + AsyncSeek> AsyncSeek for BufStream<RW>

在底层流中按字节偏移量定位。

使用 SeekFrom::Current(_) 进行定位时，所用的位置是假设 BufStream 没有内部缓冲区时底层流应处的位置。

定位操作始终会丢弃内部缓冲区，即使定位的位置本应落在该缓冲区内。 这保证在定位之后立即调用 .into_inner() 得到的底层读取器与定位时所处的位置一致。

更多详情请参阅 AsyncSeek。

注意：在边界情况下，当你使用 SeekFrom::Current(n) 进行定位时，如果 n 减去内部缓冲区长度会溢出 i64，则会执行两次定位而不是一次。 如果第二次定位返回 Err，则底层读取器将停留在与使用 SeekFrom::Current(0) 调用 seek 相同的位置上。

fn start_seek(self: Pin<&mut Self>, position: SeekFrom) -> Result<()>

Attempts to seek to an offset, in bytes, in a stream. 更多信息

fn poll_complete( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<u64>>

Waits for a seek operation to complete. 更多信息

impl<RW: AsyncRead + AsyncWrite> AsyncWrite for BufStream<RW>

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object. 更多信息

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize>>

Like poll_write, except that it writes from a slice of buffers. 更多信息

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation. 更多信息

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

Attempts to flush the object, ensuring that any buffered data reach their destination. 更多信息

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down. 更多信息

impl<RW: Debug> Debug for BufStream<RW>

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

使用给定的格式化器格式化此值。 更多信息

impl<RW> From<BufReader<BufWriter<RW>>> for BufStream<RW>

fn from(b: BufReader<BufWriter<RW>>) -> Self

从输入类型转换为此类型。

impl<RW> From<BufWriter<BufReader<RW>>> for BufStream<RW>

fn from(b: BufWriter<BufReader<RW>>) -> Self

从输入类型转换为此类型。

impl<'__pin, RW> Unpin for BufStream<RW>

where PinnedFieldsOf<__Origin<'__pin, RW>>: Unpin,