debouncing retroit call

debounce_sample.java

//i declare the subject globally
PublishSubject<Call<List<Response>>> subject = PublishSubject.create();

//this is how i call retrofit
private void updateMarkers(LatLng center)
  {
    subject.onNext(new APIHelper().
                    GetNearByLocations("auth_key", center.latitude, center.longitude, urgency));
    subject.debounce(1, TimeUnit.SECONDS)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeOn(Schedulers.io())
                    .subscribe(call -> {
                        call.enqueue(new Callback<List<Response>>()// should be changed to call.clone().enqueue to avoid error
                        {
                            @Override
                            public void onResponse(Call<List<Response>> call, Response<List<Response>> response)
                            {
                                if (response.code() != 200)
                                {
                                    Timber.d(errorResponse.getMessage());
                                }
                                else
                                {
                                    Timber.d("BRAVO!!!");
                                }
                            }

                            @Override
                            public void onFailure(Call<List<Response>> call, Throwable t)
                            {
                                Timber.d("something went wrong really bad");
                            }
                        });

                    });

  }