Minor tweak.
Fixes #317 Changes NetChannel.close() return to Promise<Boolean>
Update gradle wrapper.
Add a method to Promises to provide a single-use style Consumer by attaching a special Consumer that fulfills a Promise when the given Composable publishes the next value.
Change SingleUseConsumer to use CAS operations instead of a synchronized block that was insufficient to prevent a race condition when multiple threads publish values at the same time.
Add a cancelAfterUse() call on connection reconnect.
Add a toString() on Event.Headers
Move mavenCentral() to the top of the repository list in the build.
Add reference indirection and a removal of the registration from the internal list. Before it was only be removed from the cache when cancelled and not also the main list of registrations.
Make sure the previous chane is thread-safe.
Arg. Generics and 1.6 vs 1.7. :P
Switch to using channelInactive to detect a channel close event.
Fix for uninformative exception being thrown when no dispatcher is
registered with particular name. Previously internal exception from
AbstractFilter was propagated to clients making identifying of issue
quite complicated.
Merge pull request #318 from oiavorskyi/fix-get-dispatcher-exception

Fix for uninformative exception being thrown from Environment.getDispatcher()
Tweak the signature of sendAndReceive to allow for an Event type for a reply that's different than that for a request.
First cut at the Reactive Streams implementation. Several changes have been applied to the reactor.core.composable package. Major internal refactoring have updated the behavior of Composable to almost completely fulfil the Reactor Stream contract.
A Composable now doesn't rely on an Observable anymore to schedule its events nor use Event envelope type. A simple Dispatcher is required to schedule plain data processing.
An Action is a first-class citizen for user implementation to create asynchronous services. All its callback methods run asynchronously over its bound dispatcher.
Merge Master