Akka.NET Streams

Как бы вы повторяли запрос веб-службы каждые десять секунд по десять раз, пока он не ответит?

я пробовал RecoverWithRetries а также InitialDelay, но первое восстановление немедленно повторяет вызов веб-службы:

FromThirdOfContract().RecoverWithRetries(e =>
{
    return Source.FromTask(_third.GetThird(message.ContractIdLegacy)).InitialDelay(TimeSpan.FromSeconds(secondsbetween));
}, retry);

Первая повторная попытка происходит немедленно, а не через десять секунд. В Акке есть RestartSource учебный класс; у нас его нет в Akka.NET. Есть идеи?

Источник

1 ответ

Я наконец поиграл с Source.Lazily() с моим источником. Он работает, он не оценивается до первоначальной задержки вызова. Но я слушаю любые другие идеи

Источник
Другие вопросы по тегам