Crate hyperlane_broadcast 

hyperlane-broadcast

hyperlane-broadcast is a lightweight and ergonomic wrapper over Tokio’s broadcast channel designed for easy-to-use publish-subscribe messaging in async Rust applications. It simplifies the native Tokio broadcast API by providing a straightforward interface for broadcasting messages to multiple subscribers with minimal boilerplate.

Structs

Broadcast

Represents a broadcast mechanism for sending messages to multiple receivers.

BroadcastMap

Represents a concurrent, thread-safe map of broadcast channels, keyed by string.

Constants

DEFAULT_BROADCAST_SENDER_CAPACITY

Defines the default capacity for a broadcast sender.

Traits

BroadcastMapTrait

Defines the essential traits required for types that can be used as values in a BroadcastMap.

BroadcastTrait

Defines the essential traits required for types that can be broadcast.

Type Aliases

BroadcastMapReceiver

Represents a receiver endpoint for a broadcast channel within a map, allowing consumption of broadcasted messages.

BroadcastMapSendError

Represents an error that occurs when attempting to send a message via a broadcast channel within a map.

BroadcastMapSendResult

Represents the result of a broadcast map send operation, indicating either success with an optional receiver count or an error.

BroadcastMapSender

Represents a sender endpoint for a broadcast channel within a map, used to dispatch messages.

BroadcastReceiver

Represents a receiver endpoint for a broadcast channel, allowing consumption of broadcasted messages.

BroadcastSendError

Represents an error that occurs when attempting to send a message via broadcast.

BroadcastSendResult

Represents the result of a broadcast send operation, indicating either success with the number of receivers or an error.

BroadcastSender

Represents a sender endpoint for a broadcast channel, used to dispatch messages to all subscribed receivers.

Capacity

Represents the maximum capacity or buffer size of a broadcast channel.

DashMapStringBroadcast

A concurrent, thread-safe map where keys are strings and values are broadcast channels.

OptionBroadcast

Represents an optional broadcast channel.

OptionBroadcastMapReceiver

Represents an optional receiver endpoint for a broadcast channel within a map.

OptionBroadcastMapSender

Represents an optional sender endpoint for a broadcast channel within a map.

OptionReceiverCount

Represents an optional count of active receivers.

ReceiverCount

Represents the number of active receivers subscribed to a broadcast channel.