compositeDisposable.add(Flowable.create(this, BackpressureStrategy.BUFFER)
                    .subscribeOn(Schedulers.computation())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeWith(new ResourceSubscriber<...>() {
                        protected void onStart() {
                            Logger.d(TAG, "onStart called");
                            super.onStart();
                        }
                        public void onNext(...) {
                            // Eat
                            request(1);
                        }
                        public void onError(Throwable throwable) {
                        }
                        public void onComplete() {
                        }
                    }));