anchor.diff:      ns_pubsub:subscribe(ns_config_events,
                           mk_filter(InterestingNsConfigEvent), ignored),
       ns_pubsub:subscribe(mc_couch_events,
  -                        mk_filter(fun interesting_mc_couch_event/1), ignored),
  +                        mk_mc_couch_event_hander(), ignored),
   
       Self = self(),
       Watcher =
  
positive.code: interesting_ns_config_event(_Bucket, _) ->
      false.
  
  interesting_mc_couch_event({set_vbucket, _, _, _, _}) ->
      true;
  interesting_mc_couch_event({flush_all, _}) ->
      true;
  interesting_mc_couch_event(_) ->
      false.
  
  mk_filter(Pred) ->
      Self = self(),
  
negative.code:             State1 = State#state{waiters=Waiters1},
              {noreply, State1}
      end;
  
  handle_call(sync, _From, State) ->
      {reply, ok, sync(State)};
  
  handle_call(_Request, _From, State) ->
      {reply, ok, State}.
  