Struct Dispatcher

pub struct Dispatcher { /* private fields */ }

Peer-messages dispatcher.

Implementations

impl Dispatcher

pub fn new( channels: Arc<Mutex<HashMap<SocketAddr, UnboundedSender<String>>>>, ) -> Self

Creates a new dispatcher

pub fn push_message( &self, peer_addr: &SocketAddr, msg: String, ) -> Result<(), PushMessageError>

Pushes message to given peer

pub fn is_connected(&self, socket_addr: &SocketAddr) -> bool

Returns true if the peer is still connnected

pub fn peer_count(&self) -> usize

Returns current peer count.

Trait Implementations

impl Clone for Dispatcher

fn clone(&self) -> Dispatcher

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.