anchor.diff:                                  true ->
                                       lager:info("Change is inflation: ~p ~p",
                                                  [V#dv.value, Value]),
  -                                    execute(Functions),
  +                                    execute(Functions, State),
                                       {reply, {ok, NextKey}, State};
                                   false ->
                                       lager:info("Change is not inflation!"),
  
positive.code:     lists:member(Type, [riak_dt_gcounter, riak_dt_lwwreg, riak_dt_gset]).
  
  %% @doc Execute a series of functions.
  execute({Module, Function, Args}) ->
      lager:info("Re-executing: ~p ~p ~p", [Module, Function, Args]),
      derflow:thread(Module, Function, Args);
  execute(Functions) ->
      [execute(Function) || Function <- Functions].
  
  %% @doc Declare a new variable.
  internal_declare(Id, Type, #state{variables=Variables}) ->
  
negative.code:     end,
      true = ets:insert(Variables, {Id, Record}),
      {ok, Id}.
  
  %% @doc Perform a thread operation locally.
  internal_thread(Module, Function, Args) ->
      Fun = fun() ->
              put(initial_call, {Module, Function, Args}),
              erlang:apply(Module, Function, Args)
      end,
      Pid = spawn(Fun),
      lager:info("Spawned process ~p executing ~p",
                 [Pid, {Module, Function, Args}]),
      {ok, Pid}.
  