Struct jsonrpc_tcp_server::Dispatcher

pub struct Dispatcher { /* fields omitted */ }

Peer-messages dispatcher.

Methods

impl Dispatcher

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

Creates a new dispatcher

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

Pushes message to given peer

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

Returns true if the peer is still connnected

fn peer_count(&self) -> usize

Returns current peer count.