anchor.diff:                     channel=Channel,
                      message=Message,
                      num_responses=0,
  +                   pids=[],
                      replies=[]},
       {ok, prepare, State, 0}.
   
  
positive.code: %%% Internal Functions
  %%%===================================================================
  
  %% @doc Trigger repair.
  repair([{IndexNode, Pids}|Replies],
         #state{channel=Channel}=State) ->
      riak_pubsub_subscribe_vnode:repair(IndexNode, Channel, Pids),
      repair(Replies, State);
  repair([], _State) -> ok.
  
  
negative.code: 
              case NumResponses =:= ?N of
                  true ->
                      {next_state, finalize, State#state{pids=Pids}, 0};
                  false ->
                      {next_state, waiting_n, State#state{pids=Pids}}
              end;
          false ->
              {next_state, waiting, State}
  