reactor/reactor — pull request #153 by sshcherbakov (2013-07-30 15:02:26+00:00)
Title: #152: Added synchronization to the Stream.collect() consumer

...to synchronize access to the batch consumer internal state. A unit test illustrating the issue and the fix is added too.