> Any waiting is redundant here, and only wastes capacity. I'd find > it surprising if nobody else has a requirement to just process whatever has > arrived and not wait for any more.
Time frames or message count (or the other predicate) are required to define "whatever" in "whatever has arrived" :) . Messages are collected one by one. It indicates that your completion predicate would complete as soon as aggregator collected one message. That's why it makes no sense. Laters! -- Henryk Konsek http://henryk-konsek.blogspot.com
