Struct jsonrpc_tcp_server::Dispatcher

[+] Show declaration

pub struct Dispatcher { /* fields omitted */ }

[−] Expand description

Peer-messages dispatcher.

Methods

impl Dispatcher[−]

pub fn new(channels: Arc<Mutex<HashMap<SocketAddr, Sender<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[+]

[+] Show hidden undocumented items

fn clone(&self) -> Dispatcher[−]

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)[−]

Performs copy-assignment from source.