feat: more stability tests

fuatakgun · Nov 24, 2023 · de39e3e · de39e3e
1 parent 47ac0d5
commit de39e3e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/custom_components/eufy_security/eufy_security_api/camera.py b/custom_components/eufy_security/eufy_security_api/camera.py
@@ -101,8 +101,8 @@ async def _handle_livestream_video_data_received(self, event: Event):
         await self.video_queue.put(event.data["buffer"]["data"])
 
     async def _handle_livestream_audio_data_received(self, event: Event):
-        #pass
-        await self.audio_queue.put(event.data["buffer"]["data"])
+        pass
+        #await self.audio_queue.put(event.data["buffer"]["data"])
 
     async def _initiate_start_stream(self, stream_type) -> bool:
         self.set_stream_prodiver(stream_type)

diff --git a/custom_components/eufy_security/eufy_security_api/p2p_streamer.py b/custom_components/eufy_security/eufy_security_api/p2p_streamer.py
@@ -26,8 +26,8 @@ async def chunk_generator(self, queue):
         while retry < max_retry:
             try:
                 item = queue.get_nowait()
+                _LOGGER.debug(f"chunk_generator yield data {retry} - {len(item)}")
                 retry = 0
-                _LOGGER.debug(f"chunk_generator yield data - {len(item)}")
                 yield bytearray(item)
             except TimeoutError as te:
                 _LOGGER.debug(f"chunk_generator timeout Exception %s - traceback: %s", te, traceback.format_exc())