Refractoring again

google · Feb 17, 2025 · 4b66a38 · 4b66a38
1 parent f526f54
commit 4b66a38
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/apps/auracast.py b/apps/auracast.py
@@ -692,7 +692,7 @@ async def run_receive(
         def on_new_broadcast(broadcast: BroadcastScanner.Broadcast) -> None:
             if scan_result.done():
                 return
-            if broadcast_id is None or broadcast.broadcast_id == broadcast_id:
+            if broadcast_id is None or broadcast.broadcast_:id == broadcast_id:
                 scan_result.set_result(broadcast)
 
         scanner.on('new_broadcast', on_new_broadcast)
@@ -959,17 +959,16 @@ async def run_transmit(
                     ),
                 ),
             )
+            for bis_link in big.bis_links:
+                await bis_link.setup_data_path(
+                    direction=bis_link.Direction.HOST_TO_CONTROLLER
+            )
 
             iso_queues = [
                 bumble.device.IsoPacketStream(big.bis_links[0], 64),
                 bumble.device.IsoPacketStream(big.bis_links[1], 64),
             ]
 
-            for bis_link in big.bis_links:
-                await bis_link.setup_data_path(
-                    direction=bis_link.Direction.HOST_TO_CONTROLLER
-            )
-
             def on_flow():
                 data_packet_queue = iso_queues[0].data_packet_queue
                 print(