update transcribe method and add example

Author: TudorCRL

examples/rt/async/file/main.py

@@ -0,0 +1,19 @@
+
+import asyncio
+from speechmatics.rt import AsyncClient, ServerMessageType
+
+
+async def main():
+    # Create a client using environment variable SPEECHMATICS_API_KEY
+    async with AsyncClient() as client:
+        # Register event handlers
+        @client.on(ServerMessageType.ADD_TRANSCRIPT)
+        def handle_final_transcript(msg):
+            print(f"Final: {msg['metadata']['transcript']}")
+
+        # Transcribe audio file
+        with open("../../../example.wav", "rb") as audio_file:
+            await client.transcribe(audio_file)
+
+# Run the async function
+asyncio.run(main())

sdk/rt/speechmatics/rt/_async_client.py

@@ -158,7 +158,7 @@ async def stop_session(self) -> None:
                 ...     await client.stop_session()
         """
         await self._send_eos(self._seq_no)
-        await self._session_done_evt.wait() # Wait for end of transcript event to indicate we can stop listening
+        await self._session_done_evt.wait()  # Wait for end of transcript event to indicate we can stop listening
         await self.close()
 
     async def transcribe(
@@ -253,7 +253,6 @@ async def _audio_producer(self, source: BinaryIO, chunk_size: int) -> None:
             chunk_size: Chunk size for audio data
         """
         src = FileSource(source, chunk_size=chunk_size)
-        seq_no = 0
 
         try:
             async for frame in src:
@@ -262,13 +261,12 @@ async def _audio_producer(self, source: BinaryIO, chunk_size: int) -> None:
 
                 try:
                     await self.send_audio(frame)
-                    seq_no += 1
                 except Exception as e:
                     self._logger.error("Failed to send audio frame: %s", e)
                     self._session_done_evt.set()
                     break
 
-            await self._send_eos(seq_no)
+            await self.stop_session()
         except asyncio.CancelledError:
             raise
         except Exception as e: