Mono で Rx （Reactive Extensions） を使ってみました。 Mono 3.0.3 Rx 2.1 Rx は非同期やイベント処理を LINQ で実装できるようにする API で、id:fits:20130212 や id:fits:20130216 で試した Iteratee によく似ていると思います。 生産者 消費者 Iterate…

前回 id:fits:20130212 は Enumeratee.grouped() を使って行単位のファイル処理を実装しましたが、今回は Enumerator.generateM() と Enumerator.fromCallback1() をそれぞれ使って同様の処理を実装してみました。sbt のビルド定義ファイルなどは前回と同様…

id:fits:20130116 で使った Play2 の Iteratee を単体利用して行単位のファイル処理を実装してみました。 play-iteratees 2.1.0 Iteratee は Enumerator や Enumeratee と組み合わせて使用し、それぞれ以下のような役割を担います。 Enumerator : データを生…