Struct tokio_stream::wrappers::TcpListenerStream

pub struct TcpListenerStream { /* fields omitted */ }

A wrapper around TcpListener that implements Stream.

Implementations

impl TcpListenerStream

pub fn new(listener: TcpListener) -> Self

Create a new TcpListenerStream.

pub fn into_inner(self) -> TcpListener

Get back the inner TcpListener.

Trait Implementations

impl AsMut<TcpListener> for TcpListenerStream

fn as_mut(&mut self) -> &mut TcpListener

Performs the conversion.

impl AsRef<TcpListener> for TcpListenerStream

fn as_ref(&self) -> &TcpListener

Performs the conversion.

impl Debug for TcpListenerStream

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

Formats the value using the given formatter.

impl Stream for TcpListenerStream

type Item = Result<TcpStream>

Values yielded by the stream.

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

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.

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

Returns the bounds on the remaining length of the stream.