Struct links_nonblocking::connect::poll::PollHandler

pub struct PollHandler<R: PollRead, A: PollAccept<R>> { /* private fields */ }

A wrapper struct to that will use a designated thread to handle TransmittingSvcAcceptor or TransmittingSvcAcceptorRef events and resulting respective CltRecver & CltRecverRef instances

Implementations

impl<R: PollRead, A: PollAccept<R>> PollHandler<R, A>

pub fn with_events_capacity(capacity: usize) -> Self

Create a new PollHandler with a given capacity of Events on a single poll call

pub fn add_acceptor(&mut self, acceptor: A)

Add a TransmittingSvcAcceptor or TransmittingSvcAcceptorRef to the PollHandler to be polled for incoming connections. All resulting connections in the form of CltRecver will also be serviced by this PollHandler instance.

pub fn add_recver(&mut self, recver: R)

pub fn into_spawned_handler(self, name: &str) -> SpawnedPollHandler<R, A>

Spawns a new thread with a given name that will continuously poll for events of TransmittingSvcAcceptor or TransmittingSvcAcceptorRef and resulting CltRecvers instances

Trait Implementations

impl<R: PollRead, A: PollAccept<R>> Default for PollHandler<R, A>

fn default() -> Self

Returns the “default value” for a type.