Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 76f87ad6 authored by Jakub Tyszkowski's avatar Jakub Tyszkowski Committed by Automerger Merge Worker
Browse files

leaudio/testapp: Fix threading issue on callback calls am: 3f4af021 

Original change: https://googleplex-android-review.googlesource.com/c/platform/packages/modules/Bluetooth/+/19133809



Change-Id: I3066065254560e3b31ba56f7475f39cc5ff80068
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents db6b54e1 3f4af021

android/leaudio/app/src/main/java/com/android/bluetooth/leaudio/BluetoothProxy.java

+9 −9
Original line number Diff line number Diff line
@@ -88,7 +88,7 @@ public class BluetoothProxy { 
                                                .equals(groupId))

                                .collect(Collectors.toList());

            for (LeAudioDeviceStateWrapper dev : valid_devices) {

                dev.leAudioData.groupStatusMutable.setValue(

                dev.leAudioData.groupStatusMutable.postValue(

                        new Pair<>(groupId, new Pair<>(groupStatus, 0)));

            }

        }
@@ -112,8 +112,8 @@ public class BluetoothProxy { 
            LeAudioDeviceStateWrapper valid_device = valid_device_opt.get();

            LeAudioDeviceStateWrapper.LeAudioData svc_data = valid_device.leAudioData;



            svc_data.nodeStatusMutable.setValue(new Pair<>(groupId, GROUP_NODE_ADDED));

            svc_data.groupStatusMutable.setValue(new Pair<>(groupId, new Pair<>(-1, -1)));

            svc_data.nodeStatusMutable.postValue(new Pair<>(groupId, GROUP_NODE_ADDED));

            svc_data.groupStatusMutable.postValue(new Pair<>(groupId, new Pair<>(-1, -1)));

        }

        @Override

        public void onGroupNodeRemoved(BluetoothDevice device, int groupId) {
@@ -141,8 +141,8 @@ public class BluetoothProxy { 
            LeAudioDeviceStateWrapper valid_device = valid_device_opt.get();

            LeAudioDeviceStateWrapper.LeAudioData svc_data = valid_device.leAudioData;



            svc_data.nodeStatusMutable.setValue(new Pair<>(groupId, GROUP_NODE_REMOVED));

            svc_data.groupStatusMutable.setValue(new Pair<>(groupId, new Pair<>(-1, -1)));

            svc_data.nodeStatusMutable.postValue(new Pair<>(groupId, GROUP_NODE_REMOVED));

            svc_data.groupStatusMutable.postValue(new Pair<>(groupId, new Pair<>(-1, -1)));

        }

    };
@@ -155,9 +155,9 @@ public class BluetoothProxy { 
                int toState =

                        intent.getIntExtra(BluetoothAdapter.EXTRA_STATE, BluetoothAdapter.ERROR);

                if (toState == BluetoothAdapter.STATE_ON) {

                    enabledBluetoothMutable.setValue(true);

                    enabledBluetoothMutable.postValue(true);

                } else if (toState == BluetoothAdapter.STATE_OFF) {

                    enabledBluetoothMutable.setValue(false);

                    enabledBluetoothMutable.postValue(false);

                }

            }

        }
@@ -192,10 +192,10 @@ public class BluetoothProxy { 
                                            .postValue(toState == BluetoothLeAudio.STATE_CONNECTED);



                                group_id = bluetoothLeAudio.getGroupId(device);

                                svc_data.nodeStatusMutable.setValue(

                                svc_data.nodeStatusMutable.postValue(

                                        new Pair<>(group_id, GROUP_NODE_ADDED));

                                svc_data.groupStatusMutable

                                        .setValue(new Pair<>(group_id, new Pair<>(-1, -1)));

                                        .postValue(new Pair<>(group_id, new Pair<>(-1, -1)));

                                break;

                            }

                        }