anchor.diff:              {ok, State};
           {error, notfound} ->
               {error, {not_found, Key}, State};
  +        {error, disconnected} ->
  +            run(get_existing, KeyGen, _ValueGen, State);
           {error, Reason} ->
               {error, Reason, State}
       end;
  
positive.code:     case riakc_pb_socket:list_keys(State#state.pid, State#state.bucket, State#state.timeout_listkeys) of
          {ok, _Keys} ->
              {ok, State};
          {error, Reason} ->
              {error, Reason, State}
      end;
  
negative.code:                                                              {dw, State#state.dw}], State#state.timeout_write) of
                  ok ->
                      {ok, State};
                  {error, disconnected} ->
                      run(update, KeyGen, ValueGen, State);  % suboptimal, but ...
                  {error, Reason} ->
                      {error, Reason, State}
              end;
          {error, disconnected} ->
              run(update, KeyGen, ValueGen, State);
          {error, Reason} ->
              {error, Reason, State}
      end;
  