Update specs for new dialyzer

lib/event_bus.ex

@@ -12,6 +12,8 @@ defmodule EventBus do
     Topic
   }
 
+  alias EventBus.Model.Event
+
   @doc """
   Send event to all subscribers(listeners).
 

lib/event_bus/models/event.ex

@@ -29,20 +29,21 @@ defmodule EventBus.Model.Event do
   * :ttl - Time to live value
   """
   @type t :: %__MODULE__{
-          id: String.t() | integer,
-          transaction_id: String.t() | integer,
-          topic: atom,
-          data: any,
-          initialized_at: integer,
-          occurred_at: integer,
+          id: String.t() | integer(),
+          transaction_id: String.t() | integer(),
+          topic: atom(),
+          data: any(),
+          initialized_at: integer(),
+          occurred_at: integer(),
           source: String.t(),
-          ttl: integer
+          ttl: integer()
         }
 
   @doc """
   Duration of the event, and simple answer of how long does it take to generate
   this event
   """
+  @spec duration(__MODULE__.t()) :: integer()
   def duration(%__MODULE__{
         initialized_at: initialized_at,
         occurred_at: occurred_at

lib/event_bus/services/notification.ex

@@ -29,7 +29,6 @@ defmodule EventBus.Service.Notification do
   end
 
   @spec notify_listener(tuple(), tuple()) :: no_return()
-  @spec notify_listener(module(), tuple()) :: no_return()
   defp notify_listener({listener, config}, {topic, id}) do
     listener.process({config, topic, id})
   rescue
@@ -38,6 +37,7 @@ defmodule EventBus.Service.Notification do
       ObservationManager.mark_as_skipped({{listener, config}, topic, id})
   end
 
+  @spec notify_listener(module(), tuple()) :: no_return()
   defp notify_listener(listener, {topic, id}) do
     listener.process({topic, id})
   rescue

lib/event_bus/services/observation.ex

@@ -57,7 +57,7 @@ defmodule EventBus.Service.Observation do
   end
 
   @doc false
-  @spec save(tuple(), tuple()) :: :ok
+  @spec save(tuple(), tuple()) :: no_return()
   def save({topic, id}, watcher) do
     save_or_delete({topic, id}, watcher)
     :ok

lib/event_bus/services/subscription.ex

@@ -57,11 +57,13 @@ defmodule EventBus.Service.Subscription do
   end
 
   @doc false
+  @spec subscribers() :: list()
   def subscribers do
     {listeners, _topic_map} = load_state()
     listeners
   end
 
+  @spec subscribers(atom()) :: list()
   def subscribers(topic) do
     {_listeners, topic_map} = load_state()
     topic_map[topic] || []
@@ -109,10 +111,6 @@ defmodule EventBus.Service.Subscription do
   end
 
   defp init_topic_map do
-    topics = TopicManager.all()
-
-    topics
-    |> Enum.map(fn topic -> {topic, []} end)
-    |> Enum.into(%{})
+    Enum.into(TopicManager.all(), %{}, fn topic -> {topic, []} end)
   end
 end