RxLifecycleでのライフサイクルへのバインドについて

hogeObservable
    .compose(bindToLifecycle())
    .subscribeOn(Schedulers.newThread())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<Hoge> {
        @Override
        public coid onCompleted() {
            // onNext()で保存した値を呼び出して何かしらの処理をする
        }

        @Override
        public onError(Throwable e) {

        }

        @Override
        public onNext(Hoge hoge) {
          // ここでPreferenceに値を書き込む等の処理をする
        }
    });

public class MainActivity extends RxAppCompatActivity {

    private static final String TAG = "RxLifecycleAndroid";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        Log.d(TAG, "onCreate()");

        setContentView(R.layout.activity_main);

        // for Observable
        // bind to onPause()
        Observable.interval(5, TimeUnit.SECONDS)
                .doOnSubscribe(new Action0() {
                    @Override
                    public void call() {
                        Log.i(TAG, "[Observables] : Started in onCreate(), running until onPause()");
                    }
                })
                .doOnUnsubscribe(new Action0() {
                    @Override
                    public void call() {
                        Log.i(TAG, "[Observables] : Unsubscribing subscription from onCreate()");
                    }
                })
                .compose(this.<Long>bindUntilEvent(ActivityEvent.PAUSE))
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onCompleted() {
                        Log.i(TAG, "[Observables] : onCompleted()");
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.i(TAG, "[Observables] : onError()");
                    }

                    @Override
                    public void onNext(Long aLong) {
                        Log.i(TAG, "[Obsercables] : onNext()");
                    }
                });

        // for Single
        // if onPause() is executed within 5 seconds, onError (CancellationException) is called.
        Observable.interval(5, TimeUnit.SECONDS)
                .doOnSubscribe(new Action0() {
                    @Override
                    public void call() {
                        Log.i(TAG, "[Single] : Started in onCreate(), running until onPause()");
                    }
                })
                .doOnUnsubscribe(new Action0() {
                    @Override
                    public void call() {
                        Log.i(TAG, "[Single] : Unsubscribing subscription from onCreate()");
                    }
                })
                .toSingle()
                .compose(this.bindUntilEvent(ActivityEvent.PAUSE).<Long>forSingle())
                .subscribe(new SingleSubscriber<Long>() {
                    @Override
                    public void onSuccess(Long value) {
                        Log.i(TAG, "[Single] : onSuccess()");
                    }

                    @Override
                    public void onError(Throwable error) {
                        if (error instanceof CancellationException) {
                            Log.i(TAG, "[Single] : onError(CancellationException)");
                        }
                    }
                });
    }

    @Override
    protected void onResume() {
        super.onResume();

        Log.d(TAG, "onResume()");

        // for Completable
        // bindToLifecycle -> onPause();
        Observable.interval(5, TimeUnit.SECONDS)
                .doOnSubscribe(new Action0() {
                    @Override
                    public void call() {
                        Log.i(TAG, "[Completable] : Started in onCreate(), running until onResume()");
                    }
                })
                .doOnUnsubscribe(new Action0() {
                    @Override
                    public void call() {
                        Log.i(TAG, "[Completable] : Unsubscribing subscription from onResume()");
                    }
                })
                .toCompletable()
                .compose(this.bindToLifecycle().<Long>forCompletable())
                .subscribe(new CompletableSubscriber() {
                    @Override
                    public void onCompleted() {
                        Log.i(TAG, "[Completable] : onCompleted()");
                    }

                    @Override
                    public void onError(Throwable e) {
                        if (e instanceof CancellationException) {
                            Log.i(TAG, "[Completable] : onError(CancellationException)");
                        }
                    }

                    @Override
                    public void onSubscribe(Subscription d) {
                        Log.i(TAG, "[Completable] : onSubscribe()");
                    }
                });
    }

    @Override
    protected void onPause() {
        super.onPause();

        Log.d(TAG, "onPause()");
    }
}