full coverage

rebar.lock

@@ -1 +0,0 @@
-[].

src/epr.erl

@@ -27,4 +27,4 @@ run(Pids) ->
 shutdown(AggServerPid, ProcessorPids) ->
     Pids = [AggServerPid | ProcessorPids],
     % gen_server:cast(AggServerPid, stop),
-    lists:map(fun(Pid) -> gen_server:cast(Pid, stop) end, Pids).
+    lists:map(fun(Pid) -> gen_server:call(Pid, stop) end, Pids).

src/epr_data_aggregator_server.erl

@@ -18,13 +18,13 @@ init(Param) ->
 
 handle_cast({add_data, Id, Data}, State) ->
     NewState = State#{Id => Data},
-    {noreply, NewState};
-handle_cast(stop, State) ->
-    {stop, normal, State}.
+    {noreply, NewState}.
 
 handle_call(get_state, _From, State) ->
-    {reply, State, State}.
+    {reply, State, State};
+handle_call(stop, _, State) ->
+    {stop, normal, ok, State}.
 
 terminate(normal, State) ->
-    io:format(user, "Processor terminated with state: ~p~n", [State]),
+    io:format(user, "Aggregator terminated with state: ~p~n", [State]),
     ok.

src/epr_processor_server.erl

@@ -33,12 +33,10 @@ handle_cast(run, #{file_name := FileName, aggregator_server := AggServer} = Stat
             gen_server:cast(AggServer, {add_data, FileName, ProcessedData})
     end,
 
-    {noreply, State};
-handle_cast(stop, State) ->
-    {stop, normal, State}.
+    {noreply, State}.
 
-handle_call(_, _, State) ->
-    {reply, ok, State}.
+handle_call(stop, _, State) ->
+    {stop, normal, ok, State}.
 
 terminate(normal, State) ->
     io:format(user, "Processor terminated with file name: ~p~n", [State]),