Struct tokio_stream::wrappers::LinesStream

pub struct LinesStream<R> { /* fields omitted */ }

This is supported on crate feature io-util only.

A wrapper around tokio::io::Lines that implements Stream.

Implementations

impl<R> LinesStream<R>

pub fn new(lines: Lines<R>) -> Self

Create a new LinesStream.

pub fn into_inner(self) -> Lines<R>

Get back the inner Lines.

pub fn as_pin_mut(self: Pin<&mut Self>) -> Pin<&mut Lines<R>>

Obtain a pinned reference to the inner Lines<R>.

Trait Implementations

impl<R> AsMut<Lines<R>> for LinesStream<R>

fn as_mut(&mut self) -> &mut Lines<R>

Performs the conversion.

impl<R> AsRef<Lines<R>> for LinesStream<R>

fn as_ref(&self) -> &Lines<R>

Performs the conversion.

impl<R: Debug> Debug for LinesStream<R>

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

Formats the value using the given formatter.

impl<R: AsyncBufRead> Stream for LinesStream<R>

type Item = Result<String>

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

pub fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, R> Unpin for LinesStream<R> where
    __Origin<'__pin, R>: Unpin,