Struct overclock::core::TcpListenerStream

pub struct TcpListenerStream { /* private fields */ }

A wrapper around TcpListener that implements Stream.

Implementations

impl TcpListenerStream

pub fn new(listener: TcpListener) -> TcpListenerStream

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

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<TcpListener> for TcpListenerStream

fn as_ref(&self) -> &TcpListener

Converts this type into a shared reference of the (usually inferred) input type.

impl Channel for TcpListenerStream

type Event = ()

The channel Event type

type Handle = TcpListenerHandle

The sender half of the channel

type Inbox = Abortable<TcpListenerStream>

The receiver half of the channel

type Metric = GenericGauge<AtomicI64>

Metric Collector

fn channel<T>( self, scope_id: ScopeId ) -> (Self::Handle, Self::Inbox, AbortRegistration, Option<IntGauge>, Option<Box<dyn Route<()>>>)

Create a sender and receiver of the appropriate types

fn type_name() -> Cow<'static, str>

Get this channel’s name

impl Debug for TcpListenerStream

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

Formats the value using the given formatter.

impl Stream for TcpListenerStream

type Item = Result<TcpStream, Error>

Values yielded by the stream.

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

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.