anchor.diff:      case riakc_pb_socket:search(NewState#state.pid, Index, Query, Options, NewState#state.timeout_read) of
             {ok, _Results} ->
                 {ok, NewState};
  +          {error, disconnected} ->
  +              run(search, _KeyGen, _ValueGen, State);
             {error, Reason} ->
                 {error, Reason, NewState}
       end;
  
positive.code:                                                      {dw, State#state.dw}], State#state.timeout_write) of
          ok ->
              {ok, State};
          {error, Reason} ->
              {error, Reason, State}
      end;
  
negative.code:             {ok, State};
          {error, notfound} ->
              {error, {not_found, Key}, State};
          {error, disconnected} ->
              run(get_existing, KeyGen, _ValueGen, State);
          {error, Reason} ->
              {error, Reason, State}
      end;
  