anchor.diff:      {ok, State :: atom(), Data :: #data{}} |
       {stop, Reason :: term()} | ignore).
   init([]) ->
  -    MaxHeapSizeInWords = (100 bsl 20) div erlang:system_info(wordsize), %%100 MB
  +    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)),
  
positive.code: -record(data, {
      ref :: reference(),
      pid :: undefined | pid(),
      events = maps:new() :: map()
  }).
  
  
  
negative.code: -export([unconfigured/3, configuring/3, batching/3]).
  
  -define(SERVER, ?MODULE).
  -define(HEAPSIZE, 100). %% In MB
  -define(KILL_TIMER, 300000). %% 5 min
  -define(LISTEN_TIMEOUT, 1000). %% 1 secs
  
  -include_lib("stdlib/include/ms_transform.hrl").
  