Introduction · HonKitScalaz日本語ドキュメント これは、scalazに関する日本語ドキュメントです。 ソースコードのリポジトリはこちらです。 https://github.com/xuwei-k/scalaz-docs 文章内のコードはmdocによって、コンパイル、実行されています。 ライセンスはCreative Common BY-NC-SAです。 Kenji Yoshida @xuwei-k
[scalaz-stream] シーケンス番号とエンドマーク
プロダクトの開発中にわりと難しい処理がscalaz-streamでうまくさばけたのでメモ。 近い将来Buzzwordになってきそうな「Functional Reactive Programming」ですが、monadicなstreaming系のアプローチが筋がよさそうということで、scalaz-streamを実プロダクト開発に導入して試行錯誤しているところです。大規模データ系のいろいろな処理に適用していますが、かなりいい感触を得ています。 そのような応用の一つである大規模メール配信処理で出てきた要件が以下のものです。 大規模なデータ列を一つの固まりとしてストリーム上に流したい 事前にデータ列の総量は分からない データ規模が大きいので復数パケットに分割する必要がある 性能向上のため、可能な範囲で1パケットに復数データ列を格納したい ネットワーク系のプログラムではわりとよく出てくる処理だと思い
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
PurelyFunctionalConcurrency.pdf
https://github.com/scalaz/scalaz/blob/v7.1.1/example/src/main/scala/scalaz/example/WordCount.scala
