Struct jsonrpc_tcp_server::Dispatcher

pub struct Dispatcher { /* fields omitted */ }

Methods

impl Dispatcher

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

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

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

fn peer_count(&self) -> usize