Struct Sender 

pub struct Sender<T> { /* private fields */ }

Implementations

impl<T: Serialize + Send + Sync> Sender<T>

pub async fn new() -> Result<Self>

Create a new UDP sender bound to an ephemeral port.

Errors

Returns an error if the socket cannot be bound or connected.

pub async fn add_subscriber(&self, subscriber: SocketAddr)

Add a subscriber to the list of subscribers.

Concurrency

Acquires a write lock on the subscribers list to do this.

pub async fn send( &self, message: impl Into<T> + Send + Sync + Debug, ) -> Result<()>

Send a message to the UDP socket. Cancel safe.

Concurrency

Acquires a read lock on the subscribers list

Errors

Returns an error if the message cannot be serialized or sent.

Trait Implementations

impl<T> Debug for Sender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.