anchor.diff:  run(update_existing, KeyGen, ValueGen, State) ->
       Key = KeyGen(),
       case riakc_pb_socket:get(State#state.pid, State#state.bucket,
  -                             Key, [{r, State#state.r}]) of
  +                             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}]) 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:     end;
  run(listkeys, _KeyGen, _ValueGen, State) ->
      %% Pass on rw
      case riakc_pb_socket:list_keys(State#state.pid, State#state.bucket, State#state.timeout_listkeys) of
          {ok, _Keys} ->
              {ok, State};
          {error, Reason} ->
  