anchor.diff:  -record(state, {version       :: integer(),
                   ensemble_data :: ensembles(),
                   remote_peers  :: orddict(peer_id(), pid()),
  -                cluster_state :: cluster_state()
  +                cluster_state :: cluster_state(),
  +                subscribers :: [fun()]
                  }).
   
   -type state() :: #state{}.
  
positive.code:             {noreply, State}
      end;
  
  handle_call(_Request, _From, State) ->
      {reply, ok, State}.
  
  
negative.code:                  %% io:format("Should stop: ~p~n", [{Ensemble, Id}]),
                   ok = riak_ensemble_peer_sup:stop_peer(Ensemble, Id)
           end || Change <- PeerChanges],
      _ = [Callback(CS) || Callback <- Subscribers],
      State#state{ensemble_data=NewEnsData}.
  
  -spec request_remote_peers(state()) -> ok.
  