update examples

Author: TudorCRL

examples/rt/async/file/main.py

@@ -12,7 +12,7 @@ def handle_final_transcript(msg):
             print(f"Final: {msg['metadata']['transcript']}")
 
         # Transcribe audio file
-        with open("../../../example.wav", "rb") as audio_file:
+        with open("./examples/example.wav", "rb") as audio_file:
             await client.transcribe(audio_file)
 
 # Run the async function

sdk/rt/speechmatics/rt/_async_client.py

@@ -75,7 +75,6 @@ def __init__(
         conn_config: Optional[ConnectionConfig] = None,
     ) -> None:
         self._logger = get_logger("speechmatics.rt.async_client")
-        self._seq_no = 0
 
         (
             self._session,

sdk/rt/speechmatics/rt/_base_client.py

@@ -40,6 +40,7 @@ def __init__(self, transport: Transport) -> None:
         self._recv_task: Optional[asyncio.Task[None]] = None
         self._closed_evt = asyncio.Event()
         self._eos_sent = False
+        self._seq_no = 0
 
         self._logger = get_logger("speechmatics.rt.base_client")
 
@@ -119,6 +120,7 @@ async def send_audio(self, payload: bytes) -> None:
 
         try:
             await self._transport.send_message(payload)
+            self._seq_no += 1
         except Exception:
             self._closed_evt.set()
             raise