Play 2.0のIteratee、Enumerator、Enumerateeを理解できません

Question

私はPlay 2.0 Frameworkを学び始めました。私が理解できないことの1つは、play tutorialに記載されているIteratee、EnumeratorおよびEnumerateeパターンです。私は関数型言語での経験はほとんどありません。

このパターンは何を達成していますか？

ノンブロッキング/リアクティブコードの書き込みにはどのように役立ちますか？

いくつかの簡単な例が役立ちます。

Answer 1

playframework 2.0のダウンロードにはいくつかのサンプルが付属しています。 2つはIteratee/Cometの例です。例えば、彗星、クロックsample appショー：チャンクでクライアントに結果を送ります

Ok.stream(clock &> Comet(callback = "parent.clockChanged")) 

：

lazy val clock = Enumerator.fromCallback {() => 
    Promise.timeout(Some(dateFormat.format(new Date)), 100 milliseconds) 
} 

次に、それをこのように使用されます。 Enumeratorオブジェクトは、fromFile,fromStream（java.io.InputStreamのように）ユーティリティ列挙関数も持っています。

私はこれがどこで行われたのかわかりませんが、このチャンク処理がスレッドを縛っていないという前提があります。いくつかのベンチマークを見ることは非常に面白いでしょう。処理されるデータや計算がさまざまなオブジェクトにラップされるため、イテレートの実装にはオーバーヘッドがあります。

列挙子から供給されるデータは、処理するデータがさらにあるか、またはデータが最後に達したことを示すことができるようにラップされます（EOF）。 iterateesの処理結果もラップされ、ある入力で結果が計算されたかどうか、または結果を計算するためにはさらに多くの入力が必要かどうかを示すことができます。私はJohn De Goesのnescala presentationにフォールドからイテラテスへの進化を示すことをお勧めします。編集：Brendan McAdamsは、非同期と非ブロッキングの素晴らしいScala Days 2012 presentationを持っています。プレゼンテーションの終わり（〜26分）ではiterateesに触れ、非同期スタイルでデータベースカーソルスタイルIOを処理するのに役立ちます。

Iterateesの1つの宣伝された利点はそれらが構成するということです。ここでは、彼らが構成するいくつかの方法があります：あなたがenumator andThenを養うことができ

• 別
• することができますマップU
• の列挙子を取得するTの列挙子を超える種類(T) => Uの機能あなたはインターリーブ 2つの列挙子
• iterateeは別のiterateeによって消費されるいくつかの入力を残すことができます