将来のFinagleでのリクエストの無限シーケンス

Question

私は常に新しい値をチェックする必要があるHTTP APIエンドポイントを持っています。幸いにも、それは長いポーリングをサポートしています。つまり、私はリクエストを行い、応答を待つ（最大10分）、レスポンスからいくらかの価値を得て、どこかに格納して別のリクエストをして副作用を生むという「無限ループ」を実装する必要があるということです。

私はいくつかの関数を持っているので、呼び出しは '無限ループ'を開始します。また、Finagle APIを満たすためにClosableを返す必要があります。 HTTPリクエストが失敗した場合、すぐに再試行する必要があります。

これをFinagleのFutureで実装する方法を理解する必要があります。私は、将来の応答に変換を適用して再帰を使用できるかどうか疑問に思いますか？または何かが欠けていて、Finagleでそれを行うより簡単な方法がありますか？

ありがとうございます！

Answer 1

私はそれは（あなたが記述するもの）の再帰よりも、それ以上に簡単行うことができるか想像できるかわからない：これはと、実際に伝統的な意味での再帰的ではないことを、

def keepCalling: Future[Unit] = makeRequest 
    .flatMap { response => 
     processResponse(response) 
     if(cancelled) Future.Unit else keepCalling 
    } 

注意「再帰的な」呼び出しは別のスレッド上で行われるため、いつも（ある予約で）keepCallingの1つのインスタンスだけがスタックに置かれると期待する必要があります。