anchor.diff:      end.
   
   -spec state_changed(state()) -> state().
  -state_changed(State=#state{ensemble_data=EnsData, cluster_state=CS}) ->
  +state_changed(State=#state{ensemble_data=EnsData, cluster_state=CS, subscribers=Subscribers}) ->
       true = ets:insert(?ETS, {cluster_state, CS}),
       true = ets:insert(?ETS, {cluster, riak_ensemble_state:members(CS)}),
       true = ets:insert(?ETS, {enabled, riak_ensemble_state:enabled(CS)}),
  
positive.code: -record(state, {version       :: integer(),
                  ensemble_data :: ensembles(),
                  remote_peers  :: orddict(peer_id(), pid()),
                  cluster_state :: cluster_state()
                 }).
  
  -type state() :: #state{}.
  
negative.code:             true
      end.
  
  load_subscribers(State) ->
      case application:get_env(riak_ensemble, subscribers) of
          undefined->
              State#state{subscribers=[]};
          {ok, Subscribers} ->
              State#state{subscribers=Subscribers}
      end.
  
  -spec load_saved_state() -> not_found | {ok, state()}.
  load_saved_state() ->
      try
  