reactor/reactor — pull request #289 by smaldini (2014-02-15 17:55:01+00:00)
Title: fix #288

fix mapMany on groovy extention
Change collectWithTimeout() to collect().timeout()
"Various actions could benefit from a timeout, in fact even Promises will be interested in such action. A timeout action triggers a parent flush (or itself if root), releasing any Flushable action (buffer, collect, propagate, reduce, window...).
Eventually, competing events from timeout flush and natural flush can be filtered out with a distinct() method to remove duplicate noise."