X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=src%2Fbeam_stats_producer.erl;h=eab1759df2a07425446bb07b02b743a1ee55845d;hb=eb6b9342c34b63de7e57493e0cc682e97046fcca;hp=dd52692bf5eb33a8f2bac27c60214fb7715c9cf4;hpb=65416582c9dcb3442edd532b2dbb2ace5e0dfa35;p=beam_stats.git

diff --git a/src/beam_stats_producer.erl b/src/beam_stats_producer.erl
index dd52692..eab1759 100644
--- a/src/beam_stats_producer.erl
+++ b/src/beam_stats_producer.erl
@@ -30,8 +30,8 @@
 -define(PRODUCE_ASYNC , produce_async).
 
 -record(state,
-    { consumers = ordsets:new() :: ordsets:ordset(pid())
-    , deltas_server :: beam_stats_delta:t()
+    { consumers     = ordsets:new() :: ordsets:ordset(pid())
+    , deltas_server                 :: beam_stats_delta:t()
     }).
 
 -type state() ::
@@ -113,7 +113,7 @@ produce_async(#state{}=State) ->
     state().
 produce(
     #state
-    { consumers   = ConsumersSet
+    { consumers     = ConsumersSet
     , deltas_server = DeltasServer
     }=State,
     MsgSendFun
@@ -122,6 +122,7 @@ produce(
     ConsumersList = ordsets:to_list(ConsumersSet),
     Send = fun (Consumer) -> MsgSendFun(Consumer, Stats) end,
     ok = lists:foreach(Send, ConsumersList),
+    beam_stats_delta:gc(DeltasServer),
     State.
 
 -spec schedule_first_production() ->