void onRunSchedulerExampleButtonClicked() {
    sampleObservable()
            // Run on a background thread
            .subscribeOn(HandlerScheduler.from(backgroundHandler))
                    // Be notified on the main thread
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<String>() {
                @Override public void onCompleted() {
                    Log.d(TAG, "onCompleted()");
                }

                @Override public void onError(Throwable e) {
                    Log.e(TAG, "onError()", e);
                }

                @Override public void onNext(String string) {
                    Log.d(TAG, "onNext(" + string + ")");
                }
            });
}
 

void fetchSongs(String url) {
    songsObservable(url)
            // Run on a background thread
            .subscribeOn(HandlerScheduler.from(backgroundHandler))
                    // Be notified on the main thread
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<List<Song>>() {
                @Override
                public void onCompleted() {
                    Log.d(getClass().getSimpleName(), "onCompleted()");
                    progressDialog.dismiss();
                }

                @Override
                public void onError(Throwable e) {
                    Log.e(getClass().getSimpleName(), "onError()", e);
                    Toast.makeText(MainActivity.this, e.getMessage(), Toast.LENGTH_LONG).show();
                }

                @Override
                public void onNext(List<Song> songs) {
                    recyclerView.setAdapter(new JsonAdapter(songs));
                }
            });
}
 

void fetchSongs(String url) {
    songsObservable(url)
            // Run on a background thread
            .subscribeOn(HandlerScheduler.from(backgroundHandler))
                    // Be notified on the main thread
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<List<Song>>() {
                @Override
                public void onCompleted() {
                    Log.d(getClass().getSimpleName(), "onCompleted()");
                    progressDialog.dismiss();
                }

                @Override
                public void onError(Throwable e) {
                    Log.e(getClass().getSimpleName(), "onError()", e);
                    Toast.makeText(MainActivity.this, e.getMessage(), Toast.LENGTH_LONG).show();
                }

                @Override
                public void onNext(List<Song> songs) {
                    recyclerView.setAdapter(new JsonAdapter(songs));
                }
            });
}