@spec child_spec(list()) :: map()

Returns a specification to start this module under a supervisor.

See Supervisor.

Callback implementation for GenServer.init/1.

@spec publish(topic(), message()) :: :ok

Delivers a message to the given topic.

Example

iex> PubSub.publish(:my_topic, "Hi there!")
:okcopy

@spec start_link(list()) :: GenServer.on_start()

Starts the server.

@spec subscribe(pid(), topic()) :: :ok

Subscribes a process to the given topic.

Example

iex> pid = self()
iex> PubSub.subscribe(pid, :my_topic)
:okcopy

@spec subscribers(topic()) :: [pid()]

Returns a list of pids representing the processes that are currently subscribed to the given topic.

Example

iex> pid = self()
iex> PubSub.subscribe(pid, :my_topic)
iex> [subscriber] = PubSub.subscribers(:my_topic)
iex> subscriber == pid
truecopy

@spec topics() :: [topic()]

Returns a list of the current topics.

Example

iex> pid = self()
iex> PubSub.subscribe(pid, :my_topic)
iex> PubSub.subscribe(pid, :your_topic)
iex> PubSub.topics
[:my_topic, :your_topic]copy

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

Unsubscribes a process from a given topic.

Example

iex> pid = self()
iex> PubSub.unsubscribe(pid, :my_topic)
:okcopy