A broadcast mechanism for observing RPC message streams.
Uses a simple GenServer with subscriber tracking. Subscribers receive
{:acp_stream, %ACP.StreamMessage{}} messages.
Summary
Functions
Broadcast a stream message to all subscribers.
Returns a specification to start this module under a supervisor.
Broadcast an incoming message.
Broadcast an outgoing message.
Subscribe the calling process to stream messages.
Functions
Broadcast a stream message to all subscribers.
Returns a specification to start this module under a supervisor.
See Supervisor.
Broadcast an incoming message.
Broadcast an outgoing message.
Subscribe the calling process to stream messages.