feresr

    button.setOnClickListener(new View.OnClickListener() {
                @Override
                public void onClick(View v) {
                    getData(new DataSubscriber());
                }
            });
    
    public void getData(DataSubscriber subscriber) {
        Subscription s = apiEndpoints.getData()

feresr

    button.setOnClickListener(v -> getData(new DataSubscriber()));

    public void getData(DataSubscriber subscriber) {
        Subscription s = apiEndpoints.getData()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(subscriber);
        compositeSubscriptions.add(s);
    }

feresr

Observable<Data> dataStream = RxView.clicks(button)
        .flatMap(new Func1<Void, Observable<Data>>() {
            @Override
            public Observable<Data> call(Void aVoid) {
                return apiEndpoints.getData();
            }
        });

feresr

RxView.clicks(button)
        .flatMap(new Func1<Void, Observable<Data>>() {
            @Override
            public Observable<Data> call(Void aVoid) {
                return apiEndpoints
                        .getData()
                        .subscribeOn(Schedulers.io());
            }
        })
        .observeOn(AndroidSchedulers.mainThread())

feresr

    RxView.clicks(button)
            .observeOn(Schedulers.io())
            .debounce(2, TimeUnit.SECONDS)
            .flatMap(aVoid -> apiEndpoints.getData())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(...);

feresr

Observable<Data> dataStream = RxView.clicks(button)... //create the stream as before

dataStream.subscribe(data -> Log.d(TAG, "View one received the data"));
dataStream.subscribe(data -> Log.d(TAG, "View two received the data"));

feresr

Observable<Data> dataStream = Observable.just(1)
        .observeOn(Schedulers.io())
        .debounce(2, TimeUnit.SECONDS)
        .flatMap(new Func1<Integer, Observable<Data>>() {
            @Override
            public Observable<Data> call(Integer aVoid) {
                Log.d(TAG, "Performing network request...");
                return apiEndpoints.getData();
            }
        })

feresr

Observable<Data> dataStream = RxView.clicks(button)
        .observeOn(Schedulers.io())
        .debounce(2, TimeUnit.SECONDS)
        .flatMap(new Func1<Void, Observable<Data>>() {
            @Override
            public Observable<Data> call(Void aVoid) {
                Log.d(TAG, "Performing network request...");
                return apiEndpoints.getData();
            }
        })

feresr

@Override public void onNext(DataResponse response) { 
  if (response.isSuccessful()) {
    displayData(response.getData());
  } else {
    showError(response.getError());
  }
}

feresr

@Override public void onNext(DataResponse response) { 
  if (response.isSuccessful()) {
    displayData(response.getData());
  } else {
    showError(response.getError());
  }
}