Struct Topic 

pub struct Topic { /* private fields */ }

A gossip pub/sub topic.

Topics are identified by a BLAKE3 hash of their name string. When subscribed, incoming messages are validated (§1.4) and delivered to an inbox. Messages from blocked senders (§1.5) are dropped silently.

Examples

use ma_core::Topic;

let topic = Topic::new("/ma/broadcast/0.0.1");
assert_eq!(topic.name(), "/ma/broadcast/0.0.1");
assert!(!topic.is_subscribed());

Implementations

impl Topic

pub fn new(name: impl Into<String>) -> Self

Create a new topic from a protocol-style name string.

The topic starts unsubscribed. Call subscribe to begin receiving messages.

pub fn broadcast() -> Self

Create a topic for the well-known broadcast channel.

Equivalent to Topic::new("/ma/broadcast/0.0.1").

pub fn name(&self) -> &str

The human-readable topic name.

pub fn id(&self) -> &TopicId

The BLAKE3-derived topic identifier.

pub fn is_subscribed(&self) -> bool

Whether this topic is currently subscribed (has an inbox).

pub fn subscribe(&mut self)

Subscribe with a new internal inbox using the default capacity.

If already subscribed, this is a no-op.

pub fn subscribe_with(&mut self, inbox: Inbox<Message>)

Subscribe with an existing inbox, so messages from multiple sources converge into a single queue.

Replaces any previous inbox.

pub fn unsubscribe(&mut self)

Unsubscribe — stop receiving messages and drop the inbox.

pub fn deliver(&mut self, message: Message) -> bool

Deliver a message into this topic’s inbox after validation.

Returns true if the message was accepted, false if it was rejected (wrong content type, has recipient, blocked sender, expired, or not subscribed).

pub fn drain(&mut self) -> Vec<Message>

Drain all non-expired messages from the topic’s inbox.

Returns an empty Vec if not subscribed.

pub fn block(&mut self, sender_did: impl Into<String>)

Block a sender DID. Messages from this sender will be dropped before any other validation.

pub fn unblock(&mut self, sender_did: &str)

Unblock a sender DID.

pub fn is_blocked(&self, sender_did: &str) -> bool

Whether a sender DID is blocked.