End to end connected for demo #17
@@ -48,6 +48,7 @@ async def test_real_audio(mocker):
|
|||||||
audio_out_socket = AsyncMock()
|
audio_out_socket = AsyncMock()
|
||||||
|
|
||||||
vad_streamer = Streaming(audio_in_socket, audio_out_socket)
|
vad_streamer = Streaming(audio_in_socket, audio_out_socket)
|
||||||
|
vad_streamer._ready = True
|
||||||
for _ in audio_chunks:
|
for _ in audio_chunks:
|
||||||
await vad_streamer.run()
|
await vad_streamer.run()
|
||||||
|
|
||||||
|
|||||||
@@ -21,7 +21,9 @@ def streaming(audio_in_socket, audio_out_socket):
|
|||||||
import torch
|
import torch
|
||||||
|
|
||||||
torch.hub.load.return_value = (..., ...) # Mock
|
torch.hub.load.return_value = (..., ...) # Mock
|
||||||
return Streaming(audio_in_socket, audio_out_socket)
|
streaming = Streaming(audio_in_socket, audio_out_socket)
|
||||||
|
streaming._ready = True
|
||||||
|
return streaming
|
||||||
|
|
||||||
|
|
||||||
async def simulate_streaming_with_probabilities(streaming, probabilities: list[float]):
|
async def simulate_streaming_with_probabilities(streaming, probabilities: list[float]):
|
||||||
|
|||||||
Reference in New Issue
Block a user