Как обрабатывать события, отправленные сервером ASP.NET Core 10.0 (SSE) в Blazor? ⇐ C#

[Anonymous]

В ASP.NET Core 10 была добавлена ​​поддержка SSE. Я адаптировал приведенный там пример (с некоторой поддержкой из этого репозитория).
Я могу вызвать этот код с помощью Curl, и он вернет ожидаемый результат:

Код: Выделить всё

app.MapGet("/backend/heartrate", (CancellationToken cancellationToken) =>
{
async IAsyncEnumerable GetHeartRate(
[EnumeratorCancellation] CancellationToken cancellationToken)
{
while (!cancellationToken.IsCancellationRequested)
{
var heartRate = Random.Shared.Next(60, 100);
yield return heartRate;
await Task.Delay(2000, cancellationToken);
}
}

return TypedResults.ServerSentEvents(GetHeartRate(cancellationToken), eventType: "heartRate");
});

Теперь я хотел бы получать и обрабатывать SSE в моем проекте Blazor.
К сожалению, похоже, не существует клиентского кода, позволяющего справиться с этим. Я попробовал следующий код, но в потоке всегда ноль элементов.

Код: Выделить всё

private async Task GetHeartRate()
{
await using var stream = await HttpClient.GetStreamAsync("backend/heartrate");
await foreach(var item in SseParser.Create(stream).EnumerateAsync())
{
heartRate = int.Parse(item.Data);
}
}

Как правильно проанализировать этот SSE?


Подробнее здесь: https://stackoverflow.com/questions/796 ... -in-blazor