anchor.diff:      erlang:send_after(?REFRESH_INTERVAL, self(), refresh),
       {noreply, NewState};
   handle_cast(restart_done, #state{restart_pending = true} = State) ->
  -    {noreply, State#state{restart_pending = false}};
  -handle_cast(notable_event, #state{indexer = Indexer} = State) ->
  +    {noreply, State#state{restart_pending = false}}.
  +
  +handle_info(notable_event, #state{indexer = Indexer} = State) ->
       misc:flush(notable_event),
  -    {noreply, State#state{source = get_source(Indexer)}}.
  -
  +    {noreply, State#state{source = get_source(Indexer)}};
   handle_info(refresh, State) ->
       refresh_status(State),
       {noreply, State};
  
positive.code: is_notable(_) ->
      false.
  
  handle_config_event(Event, Pid) ->
      case is_notable(Event) of
          true ->
              gen_server:cast(Pid, notable_event);
          false ->
              ok
      end,
  
negative.code: handle_node_disco_event(Event, Pid) ->
      case Event of
          {ns_node_disco_events, _NodesOld, _NodesNew} ->
              notify_notable(Pid);
          false ->
              ok
      end,
  