Changed the default RingBuffer wait strategy to YieldingWaitStrategy() because it performs better in throughput tests.
Fixed a typo in the javadoc.
Added an optimized event publishing pipeline for notifying a Reactor of events for a given key. Added a prepare(Object key) method that returns a Consumer<Event<T>> that will directly invoke the registered Consumers in the appropriate thread every time accept is called. It optimizes the notification by pre-selecting the Consumers registered for that key and then simply invokes them for each accept rather than following the dynamic path to routing the events.
Groovy builder for environment - reactor - first cut
In order to simplify groovy configuration, especially for simple scripts or grails services, reactor-groovy now provides a statically checked DSL for building environment, reactors and consumers
Leave a constructor to set threadpool name
call onComplete after all consumers
Add consumer support to groovy reactor builder