Struct TopicStream 

pub struct TopicStream<T: Eq + Hash + Clone, M: Clone> { /* private fields */ }

A topic-based publish-subscribe stream that allows multiple subscribers to listen to messages associated with specific topics.

Type Parameters

• T: The type representing a topic. Must be hashable, comparable, and clonable.
• M: The message type that will be published and received. Must be clonable.

Implementations

impl<T: Eq + Hash + Clone, M: Clone> TopicStream<T, M>

pub fn new(buffer_size: usize) -> Self

Creates a new TopicStream instance with the specified buffer size.

Arguments

• buffer_size: The maximum number of messages each topic can hold in its buffer.

Returns

A new TopicStream instance.

pub fn subscribe(&self, topics: &[T]) -> MultiTopicReceiver<T, M>

Subscribes to a list of topics and returns a MultiTopicReceiver that can receive messages from them.

Arguments

• topics: A slice of topics to subscribe to.

Returns

A MultiTopicReceiver that listens to the specified topics.

pub async fn publish(&self, topic: &T, message: M) -> Result<(), SendError<M>>

Publishes a message to a specific topic. If the topic has no subscribers, the message is ignored.

Arguments

• topic: The topic to publish the message to.
• message: The message to send.

Returns

• Ok(()): If the message was successfully sent or there were no subscribers.
• Err(SendError): If there was an error sending the message.

Trait Implementations

impl<T: Clone + Eq + Hash + Clone, M: Clone + Clone> Clone for TopicStream<T, M>

fn clone(&self) -> TopicStream<T, M>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + Eq + Hash + Clone, M: Debug + Clone> Debug for TopicStream<T, M>

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

Formats the value using the given formatter.