Function recv_results

client_python.py:128–134

()

                    await ws.send(chunk.tobytes())

        async def recv_results():
            async for msg in ws:
                data = json.loads(msg)
                if "sentences" in data:
                    print_result(data, show_spk=args.spk)
                if data.get("is_final") or data.get("event") == "stopped":
                    break

        send_task = asyncio.create_task(send_audio())
        recv_task = asyncio.create_task(recv_results())