//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.clone().enqueue(new Callback<List<Response>>()
                    {
                        @Override
                        public void onResponse(Call<List<Response>> call, Response<List<Response>> response)
                        {
                             Timber.d("BRAVO!!!");
                        }

                        @Override
                        public void onFailure(Call<List<Response>> call, Throwable t)
                        {
                            Timber.d("someone's gonna get hurt real bad!!!");
                        }
                    });

                });
  }

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

private void updateMarkers(LatLng center)
{
    subject.onNext(new APIHelper().
            GetNearByLocations("auth_key", center.latitude, center.longitude, urgency));

}

@Override
public void onResume(Context ctx) {


       subject.debounce(1, TimeUnit.SECONDS)
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe(call -> {
                call.clone().enqueue(new Callback<List<Response>>()
                {
                    @Override
                    public void onResponse(Call<List<Response>> call, Response<List<Response>> response)
                    {
                         Timber.d("BRAVO!!!");
                    }

                    @Override
                    public void onFailure(Call<List<Response>> call, Throwable t)
                    {
                        Timber.d("someone's gonna get hurt real bad!!!");
                    }
                });

            });
}

public interface MyApi {
            Observable<String> getNearByLocation(Double latitude, Double longitude);
 }

//i declare the subject globally
PublishSubject<LatLng> subject = PublishSubject.create();

private void updateMarkers(LatLng center)
{
    subject.onNext(center);
}

public void onCreate(Context ctx) {

       subject.debounce(1, TimeUnit.SECONDS)
              .subscribeOn(Schedulers.io())
              .flatMap(latLng -> api.getNearByLocation(latLng.latitude, latLng.longitude))
              .observeOn(AndroidSchedulers.mainThread())
              .subscribe(r -> Timber.d("BRAVO !"), e -> Timber.d("Problems"));

}