我有一个 HTTP API 端点，我需要不断检查新值。幸运的是，它支持长轮询。所以我的想法是我需要实现“无限循环”，在其中我发出请求，等待响应（最多 10 分钟），从响应中获取一些值并通过将它们存储在某处产生副作用，发出另一个请求。
鉴于我有一些函数调用将启动这个“无限循环”，我还需要返回一个Closable 以满足我正在集成的 Finagle API，以便可以中断该过程。如果 HTTP 请求失败，我需要立即重试。
现在我需要弄清楚如何在 Finagle 中使用 Futures 来实现这一点。我想知道我是否可以通过对响应 Future 应用转换来使用递归？.. 还是我遗漏了一些东西，在 Finagle 中有更直接的方法来做到这一点？
谢谢！
【问题讨论】：
time.awakeEvery.map(<do http call>) 解决了。
我不确定我能否想象它（你所描述的）如何比递归更直接：
def keepCalling: Future[Unit] = makeRequest
.flatMap { response =>
processResponse(response)
if(cancelled) Future.Unit else keepCalling
}
请注意，这实际上不是传统意义上的递归，因为我们通常应该期望（有一些保留）在任何给定时间只有一个 keepCalling 实例在堆栈上，因为“递归”调用发生在不同的线程上。
【讨论】：
canceled？ var?还是有更好的方法来做到这一点？
cancelled ...是的，我猜是var。在这样的简单案例中，不需要任何更花哨的东西。请务必将其设为volatile，以便在一个线程中进行的更新能够被另一个线程正确看到。
makeRequest 将返回一个失败的未来怎么办？ “循环”会刹车吗？我们应该使用其他东西而不是flatMap 来“重试”吗？
.flatMap 之前插入.rescue 或.handle 来处理异常。