使用RxJava2时Kotlin类型可空性推断异常问题

嘿，我来帮你捋清楚这个困扰你的问题——这不是Android Studio的bug，而是Kotlin和RxJava互操作时，空安全与泛型类型推断交互产生的常见坑，咱们一步步拆解：

问题根源拆解 #

1. 为什么最初的代码没报错，但逻辑存在隐患？ #

你的函数声明返回Observable<BluetoothDevice>，但map操作实际上返回的是BluetoothDevice?（可能为null）。之所以IDE没立刻报错，是因为RxJava是基于Java实现的，而Java的泛型不区分可空/非空类型。Kotlin在与Java泛型互操作时会使用平台类型，这就导致IDE暂时允许了这种“非空声明但实际返回可空”的不匹配，不过这是非常不安全的——运行时一旦出现null，就会抛出NullPointerException。

2. 为什么添加filter { it != null }后出现怪异现象？ #

当你加上这个filter时，IDE的类型推断出现了混乱：

• 它先根据函数的返回声明，误以为map输出的是Observable<BluetoothDevice>（非空），所以推断it是BluetoothDevice，自然会提示“it != null始终为真”；
• 但实际上map返回的是可空类型，IDE又无法在链式调用中准确追踪类型变化，最终错误地把filter后的返回类型推断为Observable<BluetoothDevice?>，和你的函数声明矛盾。

解决方法 #

方法一：用mapNotNull替代map + filter（最推荐） #

RxJava的Kotlin扩展提供了mapNotNull操作符，它会自动过滤掉null值，同时直接返回非空类型的Observable，完美匹配你的函数声明：

fun discoverDevices(): Observable<BluetoothDevice> {
    val discovered: MutableSet<BluetoothDevice> = ConcurrentHashMap.newKeySet() // 改用线程安全集合，避免并发问题
    return bluetoothUtil.startDiscovery()
        .flatMapObservable { discoveryStarted ->
            if(discoveryStarted) {
                RxBroadcastReceiver.create(appContext, IntentFilter().apply {
                    addAction(BluetoothDevice.ACTION_FOUND)
                    addAction(BluetoothAdapter.ACTION_DISCOVERY_FINISHED)
                })
            } else {
                Observable.error(Throwable("Discovery couldn't be started"))
            }
        }
        .takeUntil { intent -> intent.action == BluetoothAdapter.ACTION_DISCOVERY_FINISHED }
        .mapNotNull { intent ->
            val bluetoothDevice = if(intent.action == BluetoothDevice.ACTION_FOUND) {
                intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE)
            } else {
                null
            }
            if(bluetoothDevice != null && !discovered.contains(bluetoothDevice)) bluetoothDevice else null
        }
}

另外注意：我把HashSet换成了ConcurrentHashMap.newKeySet()，因为RxJava的链式调用可能在不同线程执行，普通HashSet不是线程安全的，容易引发并发修改异常。

方法二：明确指定map的泛型类型 #

如果你坚持用map + filter，可以明确指定map返回可空类型，让IDE清晰识别类型，再配合filter和cast来修正类型：

fun discoverDevices(): Observable<BluetoothDevice> {
    val discovered: MutableSet<BluetoothDevice> = ConcurrentHashMap.newKeySet()
    return bluetoothUtil.startDiscovery()
        .flatMapObservable { discoveryStarted ->
            // ... 这里代码不变
        }
        .takeUntil { intent -> intent.action == BluetoothAdapter.ACTION_DISCOVERY_FINISHED }
        .map<BluetoothDevice?> { intent ->
            // ... 这里map逻辑不变
        }
        .filter { it != null }
        .cast(BluetoothDevice::class.java) // 明确转换为非空类型
}

明确指定map<BluetoothDevice?>后，IDE就会正确识别it是可空类型，不会再提示“条件始终为真”，最后用cast把Observable的类型修正为非空。

总结 #

这个问题本质是Kotlin的空安全特性与Java泛型的“擦除”特性在RxJava链式调用中的碰撞，并非IDE的bug。通过使用mapNotNull或者明确指定泛型类型，就能彻底解决这个怪异的类型推断问题，同时让代码更安全。

内容的提问来源于stack exchange，提问作者Ernest Zamelczyk