Struct jsonrpc_tcp_server::Dispatcher

pub struct Dispatcher { /* fields omitted */ }

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.