结构体 Split 

pub struct Split<R> { /* private fields */ }

split 方法使用的分割器。

Split 可以通过 SplitStream 转换为 Stream。

实现

impl<R> Split<R>

where R: AsyncBufRead + Unpin,

pub async fn next_segment(&mut self) -> Result<Option<Vec<u8>>>

返回流中的下一段。

示例

use tokio::io::AsyncBufReadExt;

let mut segments = my_buf_read.split(b'f');

while let Some(segment) = segments.next_segment().await? {
    println!("length = {}", segment.len())
}

impl<R> Split<R>

where R: AsyncBufRead,

pub fn poll_next_segment( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<Option<Vec<u8>>>>

轮询流中的下一段。

此方法返回：

• Poll::Pending if the next segment is not yet available.
• Poll::Ready(Ok(Some(segment))) if the next segment is available.
• Poll::Ready(Ok(None)) if there are no more segments in this stream.
• Poll::Ready(Err(err)) if an IO error occurred while reading the next segment.

当方法返回 Poll::Pending 时，传入的 Context 中的 Waker 会被调度， 以便在底层 I/O 资源上有更多字节可用时收到唤醒通知。

请注意，对 poll_next_segment 的多次调用中， 只有最近一次调用传入的 Context 中的 Waker 会被调度接收唤醒。

Trait 实现

impl<R: Debug> Debug for Split<R>

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

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

impl<'__pin, R> Unpin for Split<R>

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