diff --git a/clients/aws-sdk-transcribe-streaming/examples/simple_file.py b/clients/aws-sdk-transcribe-streaming/examples/simple_file.py index 45020e1..8c3fe6d 100644 --- a/clients/aws-sdk-transcribe-streaming/examples/simple_file.py +++ b/clients/aws-sdk-transcribe-streaming/examples/simple_file.py @@ -112,10 +112,6 @@ async def write_chunks(audio_stream: EventPublisher[AudioStream]): audio_stream, reader, BYTES_PER_SAMPLE, SAMPLE_RATE, CHANNEL_NUMS ) - # Send an empty audio event to signal end of input - await audio_stream.send(AudioStreamAudioEvent(value=AudioEvent(audio_chunk=b""))) - # Small delay to ensure empty frame is sent before close - await asyncio.sleep(0.4) await audio_stream.close() diff --git a/clients/aws-sdk-transcribe-streaming/tests/integration/test_bidirectional_streaming.py b/clients/aws-sdk-transcribe-streaming/tests/integration/test_bidirectional_streaming.py index 7c6e2fb..b58a014 100644 --- a/clients/aws-sdk-transcribe-streaming/tests/integration/test_bidirectional_streaming.py +++ b/clients/aws-sdk-transcribe-streaming/tests/integration/test_bidirectional_streaming.py @@ -49,11 +49,6 @@ async def _send_audio_chunks( wait_time = start_time + elapsed_audio_time - time.time() await asyncio.sleep(wait_time) - # Send an empty audio event to signal end of input - await stream.input_stream.send( - AudioStreamAudioEvent(value=AudioEvent(audio_chunk=b"")) - ) - await asyncio.sleep(1.2) await stream.input_stream.close()