Struct WshMultiProxy 

pub struct WshMultiProxy {
    proxies: Arc<Mutex<HashMap<String, Sender<Vec<u8>>>>>,
}

Multi-connection broadcast proxy. Sends messages to multiple remote connections simultaneously.

Fields

proxies: Arc<Mutex<HashMap<String, Sender<Vec<u8>>>>>

Implementations

impl WshMultiProxy

pub fn new() -> Self

pub fn add_proxy(&self, name: &str, sender: Sender<Vec<u8>>)

Add a named proxy connection.

pub fn remove_proxy(&self, name: &str)

Remove a named proxy connection.

pub async fn broadcast(&self, msg: Vec<u8>)

Broadcast a message to all connected proxies.

pub async fn broadcast_rpc_message( &self, msg: &RpcMessage, ) -> Result<(), String>

Broadcast an RPC message to all connected proxies.

pub fn proxy_count(&self) -> usize

Get the count of connected proxies.

pub fn proxy_names(&self) -> Vec<String>

Get names of all connected proxies.

Trait Implementations

impl Default for WshMultiProxy

fn default() -> Self

Returns the “default value” for a type.