anchor.diff:                  false ->
                       schedule_event()
               end,
  -            Events1;
  +            {Events1, BatchStart2, BatchEvents1};
           false ->
               schedule_event(),
  -            Events0
  +            {Events0, undefined, 0}
       end,
   
  -    {noreply, State#state{events=LocalEvents}};
  +    {noreply, State#state{batch_events=BatchEvents,
  +                          batch_start=BatchStart,
  +                          events=LocalEvents}};
   
   handle_info(check_simulation_end, #state{actor=Actor}=State) ->
       lasp_marathon_simulations:log_message_queue_size("check_simulation_end"),
  
positive.code:     case lasp_config:get(instrumentation, false) of
          true ->
              lasp_instrumentation:convergence();
          false ->
              ok
      end.
  
negative.code:                end),
      lager:info("Configured."),
  
      {ok, #state{actor=Actor,
                  events=0,
                  batch_start=undefined,
                  batch_events=0}}.
  
  %% @private
  -spec handle_call(term(), {pid(), term()}, #state{}) ->
  