В ASP.NET CORE 10 была добавлена поддержка SSES. Я адаптировал приведенный пример (при некоторой поддержке из этого репозитория). < /P>
Я могу вызвать этот код с помощью Curl, и он возвращает ожидаемый вывод: < /p>
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");
});
< /code>
Теперь я хотел бы получить и обработать 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);
}
}
В ASP.NET CORE 10 была добавлена поддержка SSES. Я адаптировал приведенный пример (при некоторой поддержке из этого репозитория). < /P> Я могу вызвать этот код с помощью Curl, и он возвращает ожидаемый вывод: < /p> [code]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"); }); < /code> Теперь я хотел бы получить и обработать 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); } } [/code] Как правильно проанализировать этот SSE?