视图持有中的Android - Rx可观察订阅:如何处理生命周期？

implementation 'com.trello.rxlifecycle3:rxlifecycle:3.1.0'
implementation 'com.trello.rxlifecycle3:rxlifecycle-android:3.1.0'
implementation 'com.trello.rxlifecycle3:rxlifecycle-components:3.1.0'

public class MainActivity extends AppCompatActivity implements LifecycleProvider<ActivityEvent> {

    private final BehaviorSubject<ActivityEvent> lifecycleSubject = BehaviorSubject.create();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 将Activity的生命周期事件发送给lifecycleSubject
        lifecycleSubject.onNext(ActivityEvent.CREATE);

        // 创建Observable并与生命周期进行绑定
        Observable.interval(1, TimeUnit.SECONDS)
                .compose(bindUntilEvent(ActivityEvent.DESTROY))
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        // 订阅时的操作
                    }

                    @Override
                    public void onNext(Long aLong) {
                        // 接收到数据的操作
                    }

                    @Override
                    public void onError(Throwable e) {
                        // 发生错误的操作
                    }

                    @Override
                    public void onComplete() {
                        // 完成的操作
                    }
                });
    }

    @NonNull
    @Override
    public Observable<ActivityEvent> lifecycle() {
        return lifecycleSubject.hide();
    }

    @NonNull
    @Override
    public <T> LifecycleTransformer<T> bindUntilEvent(@NonNull ActivityEvent event) {
        return RxLifecycle.bindUntilEvent(lifecycleSubject, event);
    }

    @NonNull
    @Override
    public <T> LifecycleTransformer<T> bindToLifecycle() {
        return RxLifecycle.bind(lifecycleSubject, ActivityEvent.DESTROY);
    }
}