pub async fn diffuse_message_without_lock(
message: &Message,
local_addr: SocketAddr,
site_id: &str,
connected_nei_addr: Vec<SocketAddr>,
parent_address: SocketAddr,
) -> Result<(), Box<dyn Error>>
Expand description
Implement our wave diffusion protocol
Diffuse a message without locking the app state