RxSubscriber

gistfile1.txt

    private static final class ConcertDataSubscriber extends Subscriber<ConcertItem> {

        private final ConcertListAdapter adapter;

        private ConcertDataSubscriber(final ConcertListAdapter adapter) {
            this.adapter = adapter;
        }

        @Override
        public void onCompleted() {
            unsubscribe();
        }

        @Override
        public void onError(final Throwable e) {
            Log.e("while loading data", e);
        }

        @Override
        public void onNext(final ConcertItem item) {
            adapter.addConcertItem(item);
        }
    }