结构体 Lines 

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

从 AsyncBufRead 读取行。

Lines 可以通过 LinesStream 转换为 Stream。

此类型通常通过 lines 方法创建。

实现

impl<R> Lines<R>

where R: AsyncBufRead + Unpin,

pub async fn next_line(&mut self) -> Result<Option<String>>

返回流中的下一行。

Cancel safety

此方法是可取消安全的。

示例

use tokio::io::AsyncBufReadExt;

let mut lines = my_buf_read.lines();

while let Some(line) = lines.next_line().await? {
    println!("length = {}", line.len())
}

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

获取底层读取器的可变引用。

pub fn get_ref(&mut self) -> &R

获取底层读取器的引用。

pub fn into_inner(self) -> R

解包此 Lines<R>，返回底层的读取器。

注意，内部缓冲区中任何剩余的数据都会丢失。 因此，接下来从底层读取器进行读取可能会导致数据丢失。

impl<R> Lines<R>

where R: AsyncBufRead,

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

轮询流中的下一行。

此方法返回：

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

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

Trait 实现

impl<R: Debug> Debug for Lines<R>

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

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

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

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