Renamed producer and consumers

Kalimaha · Apr 4, 2018 · b787555 · b787555
1 parent 4ac0946
commit b787555
Show file tree

Hide file tree

Showing 6 changed files with 11 additions and 11 deletions.
diff --git a/lib/weather_station_manager.ex b/lib/weather_station_manager.ex
@@ -10,9 +10,9 @@ defmodule WeatherStationManager do
     children = [
       supervisor(WeatherStationManager.Repo, []),
       supervisor(WeatherStationManager.Endpoint, []),
-      worker(UpdatesManager, []),
-      worker(UpdatesDBWorker, []),
-      worker(UpdatesTwitterWorker, [])
+      worker(UpdatesProducer, []),
+      worker(UpdatesDBConsumer, []),
+      worker(UpdatesTwitterConsumer, [])
     ]
 
     # See http://elixir-lang.org/docs/stable/elixir/Supervisor.html

diff --git a/test/controllers/updates_controller_test.exs b/test/controllers/updates_controller_test.exs
@@ -13,10 +13,10 @@ defmodule WeatherStationManager.UpdatesControllerTest do
   end
 
   test "the update is broadcasted to the workers", %{conn: conn} do
-    with_mock UpdatesManager, [broadcast_update: fn(_spam) -> :eggs end] do
+    with_mock UpdatesProducer, [broadcast_update: fn(_spam) -> :eggs end] do
       post conn, "/api/updates", @update
 
-      assert called UpdatesManager.broadcast_update(@update)
+      assert called UpdatesProducer.broadcast_update(@update)
     end
   end
 end
diff --git a/web/controllers/updates_controller.ex b/web/controllers/updates_controller.ex
@@ -2,7 +2,7 @@ defmodule WeatherStationManager.UpdatesController do
   use WeatherStationManager.Web, :controller
 
   def create(conn, params) do
-    UpdatesManager.broadcast_update(params)
+    UpdatesProducer.broadcast_update(params)
 
     conn
     |> put_status(201)

diff --git a/web/stages/updates_db_worker.ex → web/stages/updates_db_consumer.ex b/web/stages/updates_db_worker.ex → web/stages/updates_db_consumer.ex
@@ -1,4 +1,4 @@
-defmodule UpdatesDBWorker do
+defmodule UpdatesDBConsumer do
   use GenStage
 
   require Logger
@@ -8,7 +8,7 @@ defmodule UpdatesDBWorker do
   end
 
   def init(:ok) do
-    { :consumer, :ok, subscribe_to: [ UpdatesManager ] }
+    { :consumer, :ok, subscribe_to: [ UpdatesProducer ] }
   end
 
   def handle_events(events, _from, state) do

diff --git a/web/stages/updates_manager.ex → web/stages/updates_producer.ex b/web/stages/updates_manager.ex → web/stages/updates_producer.ex
@@ -1,4 +1,4 @@
-defmodule UpdatesManager do
+defmodule UpdatesProducer do
   use GenStage
 
   require Logger

diff --git a/web/stages/updates_twitter_worker.ex → web/stages/updates_twitter_consumer.ex b/web/stages/updates_twitter_worker.ex → web/stages/updates_twitter_consumer.ex
@@ -1,4 +1,4 @@
-defmodule UpdatesTwitterWorker do
+defmodule UpdatesTwitterConsumer do
   use GenStage
 
   require Logger
@@ -8,7 +8,7 @@ defmodule UpdatesTwitterWorker do
   end
 
   def init(:ok) do
-    { :consumer, :ok, subscribe_to: [ UpdatesManager ] }
+    { :consumer, :ok, subscribe_to: [ UpdatesProducer ] }
   end
 
   def handle_events(events, _from, state) do