anchor.diff:  %%====================================================================
   
   init([]) ->
  -    gen_server:cast(?MODULE, epl_wait),
  +    epl:subscribe(),
       {ok, #state{}}.
   
   handle_call(Request, _From, _State) ->
  
positive.code: handle_cast({unsubscribe, Pid}, State = #state{subscribers = Subs}) ->
      NewSubs = lists:delete(Pid, Subs),
      NewState = State#state{subscribers = NewSubs},
      {noreply, NewState};
  handle_cast(epl_wait, State) ->
      subscribe_for_epl_aftert_timeout(?EPLWAIT),
      {noreply, State}.
  
  handle_info({data, _Key, _Proplist}, State = #state{subscribers = Subs}) ->
      ETSCount = get_all_ets_count(),
      JSON = epl_json:encode(ETSCount, <<"ets-node-info">>),
      [Pid ! {data, JSON} || Pid <- Subs],
      {noreply, State};
  handle_info(subscribe_epl, State) ->
      epl:subscribe(),
      {noreply, State}.
  
  
  terminate(_Reason, _State) ->
      ok.
  
negative.code: 
  %% gen_server state
  -record(state, {subscribers = []}).
  
  %%====================================================================
  %% API functions
  