+-spec produce(state()) ->
+ state().
+produce(#state{consumers=ConsumersSet, stats_state=StatsState1}=State) ->
+ StatsState2 = beam_stats_state:update(StatsState1),
+ Stats = beam_stats_state:export(StatsState2),
+ ConsumersList = ordsets:to_list(ConsumersSet),
+ ok = push_to_consumers(Stats, ConsumersList),
+ State#state{stats_state = StatsState2}.
+