基本的にパブ/サブスタイルのキューである Java で書かれたライブラリがあります。インターフェイスは大まかに次のとおりです。
class Queue(subscriber: Thing => ()) {
def publish(thing: Thing) {
}
}
サブスクライバーからのイベントを表す Akka Iteratee を作成するにはどうすればよいですか? つまり、サブスクライバー関数が呼び出されるたびに、Iteratee オブジェクトに別の要素を提供するようにします。