anchor.diff:      Robj0 = riakc_obj:new(State#state.bucket, KeyGen()),
       Robj = riakc_obj:update_value(Robj0, ValueGen()),
       case riakc_pb_socket:put(State#state.pid, Robj, [{w, State#state.w},
  -                                                     {dw, State#state.dw}]) of
  +                                                     {dw, State#state.dw}], State#state.timeout_write) of
           ok ->
               {ok, State};
           {error, Reason} ->
  
positive.code: run(get, KeyGen, _ValueGen, State) ->
      Key = KeyGen(),
      case riakc_pb_socket:get(State#state.pid, State#state.bucket, Key,
                               [{r, State#state.r}]) of
          {ok, _} ->
              {ok, State};
          {error, notfound} ->
  
negative.code: run(update_existing, KeyGen, ValueGen, State) ->
      Key = KeyGen(),
      case riakc_pb_socket:get(State#state.pid, State#state.bucket,
                               Key, [{r, State#state.r}], State#state.timeout_read) of
          {ok, Robj} ->
              Robj2 = riakc_obj:update_value(Robj, ValueGen()),
              case riakc_pb_socket:put(State#state.pid, Robj2, [{w, State#state.w},
                                                                {dw, State#state.dw}], State#state.timeout_write) of
                  ok ->
                      {ok, State};
                  {error, Reason} ->
  