В 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 Project.
К сожалению, нет никакого клиентского кода о том, как справиться с этим. Я попробовал следующий код, но в потоке всегда есть нулевые элементы.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 Project. К сожалению, нет никакого клиентского кода о том, как справиться с этим. Я попробовал следующий код, но в потоке всегда есть нулевые элементы.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?
В ASP.NET CORE 10 была добавлена поддержка SSES. Я адаптировал приведенный пример (при некоторой поддержке из этого репозитория).
Я могу вызвать этот код с помощью Curl, и он возвращает ожидаемый вывод:
app.MapGet( /backend/heartrate ,...
Примерно в 2017 году я написал сценарий SSE (PHP) и код Javascipt. Отбыл нормально с PHP-5 + HTTP/1 и Firefox той эпохи. У меня есть тайм-аут через 60 секунд. Если я удаляю while зациклена что -то, что я думаю, что это плохо, это работает. В этом...
Примерно в 2017 году я написал сценарий SSE (PHP) и код Javascipt. Отбыл нормально с PHP-5 + HTTP/1 и Firefox той эпохи. У меня есть тайм-аут через 60 секунд. Если я удаляю while зациклена что -то, что я думаю, что это плохо, это работает. В этом...