RxAndroid，在activity onDestroy()中停止计时器/可观察的时间间隔

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

public class MainActivity extends AppCompatActivity {
    private Disposable disposable;

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

        // 创建一个可观察的时间间隔
        Observable<Long> intervalObservable = Observable.interval(1, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());

        // 创建一个观察者
        Observer<Long> intervalObserver = new Observer<Long>() {
            @Override
            public void onSubscribe(Disposable d) {
                disposable = d; // 保存Disposable对象
            }

            @Override
            public void onNext(Long value) {
                // 处理每个时间间隔的事件
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误
            }

            @Override
            public void onComplete() {
                // 处理完成事件
            }
        };

        // 订阅可观察对象
        intervalObservable.subscribe(intervalObserver);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (disposable != null && !disposable.isDisposed()) {
            disposable.dispose(); // 停止计时器/可观察的时间间隔
        }
    }
}