fix: report bond state before connection state

taylorbell · taylorbell · commit bd1a18b2d47d · 2025-01-06T18:07:19.000-06:00
diff --git a/packages/reactive_ble_mobile/android/src/main/kotlin/com/signify/hue/flutterreactiveble/ble/ReactiveBleClient.kt b/packages/reactive_ble_mobile/android/src/main/kotlin/com/signify/hue/flutterreactiveble/ble/ReactiveBleClient.kt
@@ -424,8 +424,6 @@ open class ReactiveBleClient(private val context: Context) : BleClient {
             )
 
     private fun onConnectionUpdate(update: ConnectionUpdate) {
-        connectionUpdateBehaviorSubject.onNext(update)
-
         when (update) {
             is ConnectionUpdateSuccess -> {
                 val device = rxBleClient.getBleDevice(update.deviceId)
@@ -440,6 +438,9 @@ open class ReactiveBleClient(private val context: Context) : BleClient {
                 )
             }
         }
+
+        connectionUpdateBehaviorSubject.onNext(update)
+
     }
 
     private val bondStateReceiver = object : BroadcastReceiver() {

Original file line number	Diff line number	Diff line change
`@@ -424,8 +424,6 @@ open class ReactiveBleClient(private val context: Context) : BleClient {`
`424`	`424`	`)`
`425`	`425`
`426`	`426`	`private fun onConnectionUpdate(update: ConnectionUpdate) {`
`427`		`- connectionUpdateBehaviorSubject.onNext(update)`
`428`		`-`
`429`	`427`	`when (update) {`
`430`	`428`	`is ConnectionUpdateSuccess -> {`
`431`	`429`	`val device = rxBleClient.getBleDevice(update.deviceId)`
`@@ -440,6 +438,9 @@ open class ReactiveBleClient(private val context: Context) : BleClient {`
`440`	`438`	`)`
`441`	`439`	`}`
`442`	`440`	`}`
	`441`	`+`
	`442`	`+ connectionUpdateBehaviorSubject.onNext(update)`
	`443`	`+`
`443`	`444`	`}`
`444`	`445`
`445`	`446`	`private val bondStateReceiver = object : BroadcastReceiver() {`