@type registered_subscribers() :: %{
  required(pid()) => [EventBroker.filter_spec_list()]
}

I am the type of the registered subscribers. I map a subscriber pid to all their filter specs.

@type t() :: %EventBroker.Registry{
  registered_filters: registered_filters(),
  registered_subscribers: registered_subscribers(),
  supervisor: atom()
}

I am the type of the Registry.

My main functionality is to keep track of all spawned filter actors.

Fields

• :supervisor - The name of the dynamic supervisor launched on start.
• :registered_filters - The map whose keys are a filter-spec dependency list and whose values are PID's of filter agents corresponding to said lists.
• :registered_subscribers - The map whose keys are a subscriber PID mapped onto their filter specs. Default: %{}