Struct bytelines::AsyncByteLines

pub struct AsyncByteLines<B> where
    B: AsyncBufRead + Unpin,  { /* private fields */ }

Provides async iteration over bytes of input, split by line.

use bytelines::*;
use std::fs::File;
use std::io::BufReader;

// construct our iterator from our file input
let file = File::open("./res/numbers.txt").await?;
let reader = BufReader::new(file);
let mut lines = AsyncByteLines::new(reader);

// walk our lines using `while` syntax
while let Some(line) = lines.next().await? {
    // do something with the line, which is &[u8]
}

This differs from the `stdlib` version of the API as it fits
more closely with the Tokio API for types. There is no current
`Stream` based API for this form as of yet.

Implementations

impl<B> AsyncByteLines<B> where
    B: AsyncBufRead + Unpin, 

pub fn new(buf: B) -> Self

Constructs a new ByteLines from an input AsyncBufRead.

pub async fn next(&mut self) -> Result<Option<&[u8]>, Error>

Retrieves a reference to the next line of bytes in the reader (if any).