У меня проблема с получением ответа на websocket

Question

Я использую websocket API для распознавания речи.Я отправляю аудио на сервер и получаю ответ.С помощью этого API веб-сокета можно получить результаты распознавания голоса во время потоковой передачи голосовых данных.Я могу получить окончательный результат распознавания, но не могу получить результат распознавания в пути.

Ниже показан ссылочный код.https://gist.github.com/arjun-g/75961830d363cc9265e4ac2ca095168b

После различных испытаний я обнаружил, что строка: 85 была проблемой.Эта часть, похоже, ожидает окончательного результата.

Возможно, я вообще не получил результат в пути.

Пожалуйста, скажите мне, почему я не могу получить результат в пути.

private async Task Connect(ClientWebSocket clientWebSocket)
        {
            CancellationTokenSource cts = new CancellationTokenSource();
            clientWebSocket.Options.SetRequestHeader("Authorization", $"Bearer {this.accessToken}");        
            Uri connection = new Uri($"wss://hogehoge");
            await clientWebSocket.ConnectAsync(connection, cts.Token);
        }

Выше приведена часть метода подключения.

Вот весь мой код.

private async Task Connect(ClientWebSocket clientWebSocket)
        {

            CancellationTokenSource cts = new CancellationTokenSource();
            clientWebSocket.Options.SetRequestHeader("Authorization", $"Bearer {this.accessToken}");
            Uri connection = new Uri($"wss://hogehoge");
            await clientWebSocket.ConnectAsync(connection, cts.Token);
        }

static async Task SendAudio(ClientWebSocket ws)
        {
            ArraySegment<byte> closingMessage = new ArraySegment<byte>(Encoding.UTF8.GetBytes(
            "{\"command\": \"recog-break\"}"
            ));
            using (FileStream fs = File.OpenRead("audio.raw"))
            {
                byte[] b = new byte[3200];
                while (fs.Read(b, 0, b.Length) > 0)
                {
                    await ws.SendAsync(new ArraySegment<byte>(b), WebSocketMessageType.Binary, true, CancellationToken.None);
                }
                await ws.SendAsync(closingMessage, WebSocketMessageType.Text, true, CancellationToken.None);
            }
        }

        // prints results until the connection closes or a delimeterMessage is recieved

private async Task HandleResults(ClientWebSocket ws)
        {
            var buffer = new byte[60000];
            while (true)
            {
                var segment = new ArraySegment<byte>(buffer);

                var result = await ws.ReceiveAsync(segment, CancellationToken.None);

                if (result.MessageType == WebSocketMessageType.Close)
                {
                    return;
                }

                int count = result.Count;
                while (!result.EndOfMessage)
                {
                    if (count >= buffer.Length)
                    {
                        await ws.CloseOutputAsync(WebSocketCloseStatus.InvalidPayloadData, "That's too long", CancellationToken.None);
                        return;
                    }
                    segment = new ArraySegment<byte>(buffer, count, buffer.Length - count);
                    result = await ws.ReceiveAsync(segment, CancellationToken.None);
                    count += result.Count;

                }
                var message = Encoding.UTF8.GetString(buffer, 0, count);

                this.textBox2.AppendText(message);

            }
        }

private async void button1_Click_1(object sender, EventArgs e)
        {
            ClientWebSocket cws = new ClientWebSocket();
            await this.Connect(cws);
            await Task.WhenAll(SendAudio(cws), HandleResults(cws));
        }