akka - Akka.NET 流

Question

您将如何每十秒重播一次 Web 服务请求，持续十次，直到它得到响应？

我试过RecoverWithRetriesand InitialDelay，但第一次恢复会立即重播 Web 服务调用：

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

第一次重试立即发生，而不是十秒后。在 Akka，有一个RestartSource类；我们在 Akka.NET 中没有它。有任何想法吗？

Answer 1

Source.Lazily()我终于和我的源一起玩了。它正在工作，在初始延迟调用之前未对其进行评估。但我正在倾听任何其他想法