[Android] 如何在 Activity 或者 Fragment 的生命周期结束时中止订阅 Observable

NavUtil

利用 NavUtil，你能够在 Activity 或 Fragment 的生命周期发生变化时，中止订阅你的 Observable。

Usage

在Activity 中，为你的 Observable 应用 compose 操做符，以下所示：

// 假设这是你的 Observable
Observable.interval(1, TimeUnit.SECONDS) 
    // 你的 Observable 将在 Activity 的 OnStopped 触发后中止发射
    .compose(NavUtil.<Long>subscribeUtilEvent(this, LifecycleEvent.ON_STOPPED))
    .subscribe(new Subscriber<Long>() {
        @Override
        public void onCompleted() {
            Log.d(TAG, "onStart onCompleted() called");
        }

        @Override
        public void onError(Throwable e) {
            Log.d(TAG, "onStart onError() called with: e = [" + e + "]");
        }

        @Override
        public void onNext(Long aLong) {
            Log.d(TAG, "onStart onNext() called with: aLong = [" + aLong + "]");
        }
    });

在 Fragment 中的用法以下所示：

// 假设这是你的 Observable
Observable.interval(1, TimeUnit.SECONDS)
    // 你的 Observable 将在 Activity 的 onPaused 触发后中止发射
    .compose(NavUtil.<Long>subscribeUtilEvent(this, LifecycleEvent.ON_PAUSED))
    .subscribe(new Subscriber<Long>() {
        @Override
        public void onCompleted() {
            Log.d(TAG, "onCompleted() called");
        }

        @Override
        public void onError(Throwable e) {
            Log.d(TAG, "onError() called with: e = [" + e + "]");
        }

        @Override
        public void onNext(Long aLong) {
            Log.d(TAG, "onNext() called with: aLong = [" + aLong + "]");
        }
    });

目前支持的生命周期事件以下所示：

public enum LifecycleEvent {
    ON_PAUSED,
    ON_STOPPED,
    ON_SAVE_INSTANCE_STATE,
    ON_DESTROYED,
    ON_VIEW_DESTORYED,
    ON_DETACHED,
}

Gradle

compile 'com.legendmohe.maven:navutil:x.y'