View Source Yggdrasil.Subscriber.Publisher (Yggdrasil v6.0.3)
A server to distribute the messages.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Notifies synchronously of a new message coming from a channel.
Notifies synchronously of a new message coming from a channel_name to a
publisher with some metadata.
Starts a server to distribute messages in a channel. Additionally can
receive GenServer options.
Stops a publisher.
Link to this section Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Notifies synchronously of a new message coming from a channel.
@spec notify( publisher :: GenServer.name(), channel_name :: term(), message :: term(), metadata :: term() ) :: :ok | {:error, term()}
Notifies synchronously of a new message coming from a channel_name to a
publisher with some metadata.
@spec start_link(Yggdrasil.Channel.t(), GenServer.options()) :: GenServer.on_start()
Starts a server to distribute messages in a channel. Additionally can
receive GenServer options.
@spec stop(GenServer.name()) :: :ok
Stops a publisher.