Bourse.WS.Broadcast (bourse v0.1.0)

Registry-backed fan-out for routed WS adapter messages.

Summary

topic()

Dispatches a message to all subscribers of a topic.

child_spec()

Child spec for the duplicate-key Registry.

subscribe(topic)

Registers the calling process for a topic.

Builds a broadcast topic from exchange id, family, and optional channel.

Unregisters the calling process from a topic.

@type topic() :: {String.t(), atom(), String.t() | nil}

@spec broadcast(topic(), term()) :: :ok

Dispatches a message to all subscribers of a topic.

@spec child_spec() :: Supervisor.child_spec()

Child spec for the duplicate-key Registry.

@spec topic(String.t(), atom(), String.t() | nil) :: topic()

Builds a broadcast topic from exchange id, family, and optional channel.

@spec unsubscribe(topic()) :: :ok

Unregisters the calling process from a topic.