Returns the next line in the stream.

Cancel safety

This method is cancel safe.

Examples

# use tokio::io::AsyncBufRead;
use tokio::io::AsyncBufReadExt;

# async fn dox(my_buf_read: impl AsyncBufRead + Unpin) -> std::io::Result<()> {
let mut lines = my_buf_read.lines();

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

Obtains a mutable reference to the underlying reader.

Obtains a reference to the underlying reader.

Unwraps this Lines<R>, returning the underlying reader.

Note that any leftover data in the internal buffer is lost. Therefore, a following read from the underlying reader may lead to data loss.

Polls for the next line in the stream.

This method returns:

• 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.

When the method returns Poll::Pending, the Waker in the provided Context is scheduled to receive a wakeup when more bytes become available on the underlying IO resource. Note that on multiple calls to poll_next_line, only the Waker from the Context passed to the most recent call is scheduled to receive a wakeup.