anchor.diff:  -record(data, {
       ref :: reference(),
       pid :: undefined | pid(),
  -    events = maps:new() :: map()
  +    events = maps:new() :: map(),
  +    kill_timer :: undefined | timer:tref()
   }).
   
   
  
positive.code: -export([unconfigured/3, configuring/3, batching/3]).
  
  -define(SERVER, ?MODULE).
  -define(LISTEN_TIMEOUT, 1000). %% 1 secs
  
  -include_lib("stdlib/include/ms_transform.hrl").
  
negative.code:     {ok, State :: atom(), Data :: #data{}} |
      {stop, Reason :: term()} | ignore).
  init([]) ->
      MaxHeapSizeInWords = (?HEAPSIZE bsl 20) div erlang:system_info(wordsize), %%100 MB
      process_flag(message_queue_data, on_heap),
      process_flag(max_heap_size, MaxHeapSizeInWords), 
      {ok, Ref} = lashup_kv_events_helper:start_link(ets:fun2ms(fun({[navstar, overlay, '_']}) -> true end)),
  