18034727885
2026-06-15 adbda87b41364461762656c52f3f938d84723484
rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
@@ -100,6 +100,11 @@
        init();
        NetStateReceiver.registerNetworkStateReceiver(this);
        // 服务重复启动时先移除旧观察者,避免重复重连回调 由AI生成
        if (mNetChangeObserver != null) {
            // 从网络监听器移除旧观察者实例 由AI生成
            NetStateReceiver.removeRegisterObserver(mNetChangeObserver);
        }
        mNetChangeObserver = new NetChangeObserver() {
            @Override
            public void onNetConnected(NetUtils.NetType type) {
@@ -151,6 +156,8 @@
    public void onDestroy() {
        super.onDestroy();
        isDestroy = true;
        // 服务销毁时移除网络观察者,避免静态列表持有 Service 引用 由AI生成
        NetStateReceiver.removeRegisterObserver(mNetChangeObserver);
        NetStateReceiver.unRegisterNetworkStateReceiver(this);
        if (subscriber != null && !subscriber.isUnsubscribed()) {
            subscriber.unsubscribe();