[projectreactor] 01/11: Merge tag 'upstream/2.0.8'

Emmanuel Bourg ebourg-guest at moszumanska.debian.org
Wed Aug 3 11:03:02 UTC 2016


This is an automated email from the git hooks/post-receive script.

ebourg-guest pushed a commit to branch master
in repository projectreactor.

commit 7a35faccce4fd50799712ac741554fc01609910f
Merge: bb02665 a2a2dbf
Author: Emmanuel Bourg <ebourg at apache.org>
Date:   Tue May 31 14:41:33 2016 +0200

    Merge tag 'upstream/2.0.8'
    
    Upstream version 2.0.8

 .gitignore                                         |    2 +
 CHANGELOG.md                                       |    2 +
 COMMITLOG.txt                                      |  304 --
 README.md                                          |   40 +-
 build.gradle                                       |  759 +++--
 gradle.properties                                  |    2 +-
 gradle/doc.gradle                                  |   96 +
 gradle/ide.gradle                                  |    6 -
 gradle/setup.gradle                                |   24 +-
 .../main/java/reactor/alloc/AbstractReference.java |   87 +
 .../src/main/java/reactor/alloc/Allocator.java     |   57 +
 .../main/java/reactor/alloc/EventAllocator.java    |   96 +
 .../java/reactor/alloc/EventFactorySupplier.java   |   42 +
 .../main/java/reactor/alloc/RecyclableNumber.java  |   69 +
 .../main/java/reactor/alloc/RecyclableString.java  |   42 +
 .../src/main/java/reactor/alloc/Reference.java     |   70 +
 .../reactor/alloc/ReferenceCountingAllocator.java  |  164 +
 .../src/main/java/reactor/alloc/package-info.java  |   20 +
 .../java/reactor/io/buffer/BufferAllocator.java    |   82 +
 .../groovy/reactor/alloc/AllocatorsSpec.groovy     |  141 +
 .../java/reactor/alloc/EventAllocatorTests.java    |   37 +
 .../resources/META-INF/reactor/custom.properties   |   18 +
 .../META-INF/reactor/override-custom.properties    |   17 +
 .../META-INF/reactor/override-default.properties   |   17 +
 .../reactor/reactor-environment.properties         |   55 +
 .../META-INF/reactor/unrecognized-type.properties  |   18 +
 reactor-alloc/src/test/resources/logback.xml       |   34 +
 reactor-bus/src/main/java/reactor/bus/Bus.java     |   60 +
 reactor-bus/src/main/java/reactor/bus/Event.java   |  506 ++++
 .../src/main/java/reactor/bus/EventBus.java        |  660 ++++
 .../java/reactor/bus/filter/AbstractFilter.java    |   33 +
 .../src/main/java/reactor/bus/filter/Filter.java   |   43 +
 .../main/java/reactor/bus/filter/FirstFilter.java  |   38 +
 .../java/reactor/bus/filter/PassThroughFilter.java |   34 +
 .../main/java/reactor/bus/filter/RandomFilter.java |   41 +
 .../java/reactor/bus/filter/RoundRobinFilter.java  |   82 +
 .../bus/filter/TraceableDelegatingFilter.java      |   52 +
 .../main/java/reactor/bus/filter/package-info.java |   20 +
 .../src/main/java/reactor/bus/package-info.java    |   20 +
 .../java/reactor/bus/publisher/BusPublisher.java   |  100 +
 .../reactor/bus/registry/CachableRegistration.java |  128 +
 .../java/reactor/bus/registry/CachingRegistry.java |  180 ++
 .../java/reactor/bus/registry/Registration.java    |  105 +
 .../main/java/reactor/bus/registry/Registries.java |   52 +
 .../main/java/reactor/bus/registry/Registry.java   |   68 +
 .../bus/registry/SimpleCachingRegistry.java        |  137 +
 .../java/reactor/bus/registry/package-info.java    |   21 +
 .../bus/routing/ConsumerFilteringRouter.java       |  115 +
 .../src/main/java/reactor/bus/routing/Router.java  |   51 +
 .../bus/routing/TraceableDelegatingRouter.java     |   54 +
 .../java/reactor/bus/routing/package-info.java     |   21 +
 .../java/reactor/bus/selector/ClassSelector.java   |   58 +
 .../java/reactor/bus/selector/HeaderResolver.java  |   40 +
 .../reactor/bus/selector/JsonPathSelector.java     |  316 ++
 .../reactor/bus/selector/MatchAllSelector.java     |   41 +
 .../java/reactor/bus/selector/ObjectSelector.java  |   97 +
 .../reactor/bus/selector/PredicateSelector.java    |   49 +
 .../java/reactor/bus/selector/RegexSelector.java   |   94 +
 .../main/java/reactor/bus/selector/Selector.java   |   52 +
 .../main/java/reactor/bus/selector/Selectors.java  |  254 ++
 .../bus/selector/SetMembershipSelector.java        |   54 +
 .../java/reactor/bus/selector/UriPathSelector.java |   76 +
 .../java/reactor/bus/selector/UriPathTemplate.java |  147 +
 .../java/reactor/bus/selector/UriSelector.java     |  179 ++
 .../java/reactor/bus/selector/package-info.java    |   20 +
 .../reactor/bus/spec/DispatcherComponentSpec.java  |  133 +
 .../main/java/reactor/bus/spec/EventBusSpec.java   |   33 +
 .../bus/spec/EventRoutingComponentSpec.java        |  252 ++
 .../main/java/reactor/bus/spec/package-info.java   |   21 +
 .../java/reactor/bus/support/CallbackEvent.java    |   65 +
 .../java/reactor/bus/support/EventConsumer.java    |   55 +
 .../java/reactor/bus/support/NotifyConsumer.java   |   59 +
 .../main/java/reactor/bus/timer/EventTimer.java    |  236 ++
 .../bus/ConsumerFilteringEventRouterSpec.groovy    |  152 +
 .../test/groovy/reactor/bus/EventBusSpec.groovy    |  502 +++
 .../test/groovy/reactor/bus/GroovyTestUtils.java   |  136 +
 .../src/test/groovy/reactor/bus/HeadersSpec.groovy |  147 +
 .../test/groovy/reactor/bus/RegistrySpec.groovy    |   55 +
 .../test/groovy/reactor/bus/SelectorSpec.groovy    |  263 ++
 .../reactor/bus/filter/FirstFilterSpec.groovy      |   59 +
 .../bus/filter/PassThroughFilterSpec.groovy        |   50 +
 .../reactor/bus/filter/RandomFilterSpec.groovy     |   61 +
 .../reactor/bus/filter/RoundRobinFilterSpec.groovy |   98 +
 .../reactor/bus/spec/ComponentSpecSpec.groovy      |   49 +
 .../java/reactor/bus/CachingAlgorithmTests.java    |  168 +
 .../src/test/java/reactor/bus/EnvironmentTest.java |   73 +
 .../test/java/reactor/bus/SelectorUnitTests.java   |  190 ++
 .../reactor/bus/registry/CachingRegistryTests.java |  215 ++
 .../reactor/reactor-environment.properties         |   55 +
 .../src/main/java/reactor/Environment.java         | 1088 +++++++
 .../main/java/reactor/alloc/AbstractReference.java |   70 -
 .../src/main/java/reactor/alloc/Allocator.java     |   39 -
 .../java/reactor/alloc/PartitionedAllocator.java   |   71 -
 .../src/main/java/reactor/alloc/Recyclable.java    |   16 -
 .../main/java/reactor/alloc/RecyclableNumber.java  |   51 -
 .../main/java/reactor/alloc/RecyclableString.java  |   24 -
 .../src/main/java/reactor/alloc/Reference.java     |   53 -
 .../reactor/alloc/ReferenceCountingAllocator.java  |  147 -
 .../java/reactor/alloc/RingBufferAllocator.java    |  205 --
 .../reactor/alloc/ThreadPartitionedAllocator.java  |   19 -
 .../alloc/factory/BatchFactorySupplier.java        |   90 -
 .../alloc/factory/EventFactorySupplier.java        |   26 -
 .../main/java/reactor/alloc/factory/Factories.java |   50 -
 .../alloc/factory/NoArgConstructorFactory.java     |   38 -
 .../src/main/java/reactor/alloc/package-info.java  |    4 -
 .../alloc/spec/RingBufferAllocatorSpec.java        |  202 --
 .../reactor/convert/ConversionFailedException.java |   58 -
 .../src/main/java/reactor/convert/Converter.java   |   46 -
 .../java/reactor/convert/DelegatingConverter.java  |   80 -
 .../java/reactor/convert/StandardConverters.java   |  197 --
 .../main/java/reactor/convert/package-info.java    |    4 -
 .../src/main/java/reactor/core/Dispatcher.java     |  110 +
 .../main/java/reactor/core/DispatcherSupplier.java |   29 +
 .../src/main/java/reactor/core/Environment.java    |  361 ---
 .../src/main/java/reactor/core/Observable.java     |  281 --
 .../src/main/java/reactor/core/Reactor.java        |  444 ---
 .../src/main/java/reactor/core/action/Action.java  |   92 -
 .../main/java/reactor/core/action/ActionUtils.java |  147 -
 .../main/java/reactor/core/action/BatchAction.java |  136 -
 .../java/reactor/core/action/BufferAction.java     |   77 -
 .../java/reactor/core/action/CallbackAction.java   |   39 -
 .../reactor/core/action/CallbackEventAction.java   |   39 -
 .../java/reactor/core/action/CollectAction.java    |   62 -
 .../java/reactor/core/action/ConnectAction.java    |   40 -
 .../main/java/reactor/core/action/CountAction.java |   47 -
 .../java/reactor/core/action/DistinctAction.java   |   46 -
 .../java/reactor/core/action/FilterAction.java     |   72 -
 .../main/java/reactor/core/action/Flushable.java   |   35 -
 .../java/reactor/core/action/FlushableAction.java  |   47 -
 .../java/reactor/core/action/ForEachAction.java    |   77 -
 .../main/java/reactor/core/action/MapAction.java   |   39 -
 .../java/reactor/core/action/MapManyAction.java    |   59 -
 .../reactor/core/action/MovingWindowAction.java    |   90 -
 .../main/java/reactor/core/action/Pipeline.java    |   46 -
 .../java/reactor/core/action/ReduceAction.java     |   69 -
 .../main/java/reactor/core/action/ScanAction.java  |   51 -
 .../java/reactor/core/action/SupplyAction.java     |   45 -
 .../java/reactor/core/action/TimeoutAction.java    |   58 -
 .../main/java/reactor/core/action/WhenAction.java  |   43 -
 .../java/reactor/core/action/WindowAction.java     |  104 -
 .../java/reactor/core/composable/Composable.java   |  580 ----
 .../java/reactor/core/composable/Deferred.java     |  139 -
 .../main/java/reactor/core/composable/Promise.java |  620 ----
 .../main/java/reactor/core/composable/Stream.java  |  745 -----
 .../java/reactor/core/composable/package-info.java |    5 -
 .../core/composable/spec/ComposableSpec.java       |   77 -
 .../core/composable/spec/DeferredPromiseSpec.java  |   55 -
 .../core/composable/spec/DeferredStreamSpec.java   |   77 -
 .../reactor/core/composable/spec/PromiseSpec.java  |   97 -
 .../reactor/core/composable/spec/Promises.java     |  350 ---
 .../reactor/core/composable/spec/StreamSpec.java   |   96 -
 .../java/reactor/core/composable/spec/Streams.java |  188 --
 .../reactor/core/composable/spec/package-info.java |    5 -
 .../reactor/core/config/ConfigurationReader.java   |   34 +
 .../core/config/DispatcherConfiguration.java       |   78 +
 .../java/reactor/core/config/DispatcherType.java   |   62 +
 .../core/config/PropertiesConfigurationReader.java |  204 ++
 .../reactor/core/config/ReactorConfiguration.java  |   75 +
 .../java/reactor/core/config/package-info.java     |   20 +
 .../core/configuration/ConfigurationReader.java    |   34 -
 .../configuration/DispatcherConfiguration.java     |   79 -
 .../reactor/core/configuration/DispatcherType.java |   56 -
 .../PropertiesConfigurationReader.java             |  203 --
 .../core/configuration/ReactorConfiguration.java   |   75 -
 .../reactor/core/configuration/package-info.java   |    4 -
 .../core/dispatch/AbstractLifecycleDispatcher.java |  212 ++
 .../java/reactor/core/dispatch/MpscDispatcher.java |  159 +
 .../core/dispatch/MultiThreadDispatcher.java       |   78 +
 .../core/dispatch/RingBufferDispatcher.java        |  296 ++
 .../core/dispatch/SingleThreadDispatcher.java      |  102 +
 .../core/dispatch/SynchronousDispatcher.java       |  112 +
 .../core/dispatch/TailRecurseDispatcher.java       |  168 +
 .../dispatch/ThreadPoolExecutorDispatcher.java     |  164 +
 .../dispatch/TraceableDelegatingDispatcher.java    |  123 +
 .../reactor/core/dispatch/WorkQueueDispatcher.java |  203 ++
 .../java/reactor/core/dispatch/package-info.java   |   21 +
 .../core/dispatch/wait/AgileWaitingStrategy.java   |   70 +
 .../core/dispatch/wait/ParkWaitStrategy.java       |   57 +
 .../reactor/core/dispatch/wait/WaitingMood.java    |   40 +
 .../java/reactor/core/dynamic/DynamicReactor.java  |   27 -
 .../core/dynamic/DynamicReactorFactory.java        |  338 ---
 .../core/dynamic/annotation/Dispatcher.java        |   49 -
 .../reactor/core/dynamic/annotation/Notify.java    |   46 -
 .../java/reactor/core/dynamic/annotation/On.java   |   50 -
 .../core/dynamic/annotation/package-info.java      |    4 -
 .../java/reactor/core/dynamic/package-info.java    |    5 -
 .../reflect/MethodNotificationKeyResolver.java     |   33 -
 .../dynamic/reflect/MethodSelectorResolver.java    |   33 -
 .../SimpleMethodNotificationKeyResolver.java       |   53 -
 .../reflect/SimpleMethodSelectorResolver.java      |   55 -
 .../reactor/core/dynamic/reflect/package-info.java |    5 -
 .../dynamic/reflect/support/AnnotationUtils.java   |   55 -
 .../dynamic/reflect/support/MethodNameUtils.java   |   57 -
 .../core/dynamic/reflect/support/package-info.java |    4 -
 .../main/java/reactor/core/fork/ForkJoinPool.java  |  122 -
 .../main/java/reactor/core/fork/ForkJoinTask.java  |  118 -
 .../reactor/core/internal/PlatformDependent.java   |   77 +
 .../reactor/core/internal/PlatformDependent0.java  |  118 +
 .../UnsafeAtomicReferenceFieldUpdater.java         |   62 +
 .../java/reactor/core/internal/package-info.java   |   25 +
 .../src/main/java/reactor/core/package-info.java   |   19 +-
 .../reactor/core/processor/CancelException.java    |   40 +
 .../core/processor/ExecutorPoweredProcessor.java   |   87 +
 .../processor/InsufficientCapacityException.java   |   45 +
 .../java/reactor/core/processor/MutableSignal.java |   17 +
 .../java/reactor/core/processor/Operation.java     |   71 -
 .../java/reactor/core/processor/Processor.java     |  255 --
 .../reactor/core/processor/ReactorProcessor.java   |   97 +
 .../core/processor/RingBufferProcessor.java        |  832 +++++
 .../core/processor/RingBufferWorkProcessor.java    |  861 ++++++
 .../java/reactor/core/processor/package-info.java  |   29 +-
 .../reactor/core/processor/spec/ProcessorSpec.java |  173 --
 .../reactor/core/processor/spec/package-info.java  |    5 -
 .../processor/util/RingBufferSubscriberUtils.java  |  243 ++
 .../core/processor/util/SingleUseExecutor.java     |  109 +
 .../core/queue/CompletableBlockingQueue.java       |   63 +
 .../reactor/core/queue/CompletableLinkedQueue.java |   40 +
 .../java/reactor/core/queue/CompletableQueue.java  |   41 +
 .../core/queue/internal/MpscLinkedQueue.java       |  398 +++
 .../queue/internal/MpscLinkedQueueHeadRef.java     |   75 +
 .../core/queue/internal/MpscLinkedQueueNode.java   |   82 +
 .../core/queue/internal/MpscLinkedQueuePad0.java   |   38 +
 .../core/queue/internal/MpscLinkedQueuePad1.java   |   41 +
 .../queue/internal/MpscLinkedQueueTailRef.java     |   58 +
 .../main/java/reactor/core/queue/package-info.java |   20 +
 .../core/reactivestreams/PublisherFactory.java     |  505 ++++
 .../core/reactivestreams/SerializedSubscriber.java |  282 ++
 .../core/reactivestreams/SubscriberBarrier.java    |  149 +
 .../core/reactivestreams/SubscriberFactory.java    |  328 ++
 .../reactivestreams/SubscriberWithContext.java     |  109 +
 .../reactivestreams/SubscriptionWithContext.java   |   87 +
 .../main/java/reactor/core/spec/ReactorSpec.java   |   34 -
 .../src/main/java/reactor/core/spec/Reactors.java  |  106 -
 .../main/java/reactor/core/spec/package-info.java  |    5 -
 .../core/spec/support/DispatcherComponentSpec.java |  178 --
 .../spec/support/EventRoutingComponentSpec.java    |  279 --
 .../reactor/core/spec/support/package-info.java    |    4 -
 .../src/main/java/reactor/core/support/Assert.java |  196 ++
 .../core/support/DefaultEnvironmentSupplier.java   |   25 -
 .../main/java/reactor/core/support/Exceptions.java |  213 ++
 .../core/support/NamedDaemonThreadFactory.java     |   91 +
 .../java/reactor/core/support/NonBlocking.java     |   41 +
 .../java/reactor/core/support/NotifyConsumer.java  |   55 -
 .../core/support/ReactorFatalException.java        |   39 +
 .../main/java/reactor/core/support/Recyclable.java |   32 +
 .../core/support/SpecificationExceptions.java      |   37 +
 .../main/java/reactor/core/support/UUIDUtils.java  |  111 +
 .../src/main/java/reactor/event/Event.java         |  506 ----
 .../java/reactor/event/alloc/EventAllocator.java   |   84 -
 .../dispatch/AbstractLifecycleDispatcher.java      |  224 --
 .../dispatch/AbstractMultiThreadDispatcher.java    |   76 -
 .../dispatch/AbstractSingleThreadDispatcher.java   |   72 -
 .../reactor/event/dispatch/ActorDispatcher.java    |  118 -
 .../java/reactor/event/dispatch/Dispatcher.java    |  104 -
 .../event/dispatch/EventLoopDispatcher.java        |   63 -
 .../reactor/event/dispatch/ParkWaitStrategy.java   |   41 -
 .../event/dispatch/RingBufferDispatcher.java       |  171 --
 .../event/dispatch/SynchronousDispatcher.java      |   87 -
 .../dispatch/ThreadPoolExecutorDispatcher.java     |  156 -
 .../dispatch/TraceableDelegatingDispatcher.java    |  101 -
 .../event/dispatch/WorkQueueDispatcher.java        |  147 -
 .../java/reactor/event/dispatch/package-info.java  |    5 -
 .../java/reactor/event/lifecycle/Pausable.java     |   46 -
 .../src/main/java/reactor/event/package-info.java  |    5 -
 .../event/registry/CachableRegistration.java       |  111 -
 .../reactor/event/registry/CachingRegistry.java    |  164 -
 .../java/reactor/event/registry/Registration.java  |  104 -
 .../main/java/reactor/event/registry/Registry.java |   67 -
 .../java/reactor/event/registry/package-info.java  |    5 -
 .../routing/ArgumentConvertingConsumerInvoker.java |  197 --
 .../routing/ConsumerFilteringEventRouter.java      |  132 -
 .../reactor/event/routing/ConsumerInvoker.java     |   46 -
 .../java/reactor/event/routing/EventRouter.java    |   49 -
 .../routing/TraceableDelegatingEventRouter.java    |   37 -
 .../java/reactor/event/routing/package-info.java   |    5 -
 .../java/reactor/event/selector/ClassSelector.java |   57 -
 .../reactor/event/selector/HeaderResolver.java     |   39 -
 .../reactor/event/selector/MatchAllSelector.java   |   25 -
 .../reactor/event/selector/ObjectSelector.java     |   88 -
 .../reactor/event/selector/PredicateSelector.java  |   33 -
 .../java/reactor/event/selector/RegexSelector.java |   94 -
 .../main/java/reactor/event/selector/Selector.java |   52 -
 .../java/reactor/event/selector/Selectors.java     |  238 --
 .../event/selector/SetMembershipSelector.java      |   38 -
 .../reactor/event/selector/UriPathSelector.java    |   81 -
 .../reactor/event/selector/UriPathTemplate.java    |  147 -
 .../java/reactor/event/selector/UriSelector.java   |  163 -
 .../java/reactor/event/selector/package-info.java  |    4 -
 .../java/reactor/event/support/CallbackEvent.java  |   49 -
 .../java/reactor/event/support/EventConsumer.java  |   55 -
 .../main/java/reactor/filter/AbstractFilter.java   |   33 -
 .../src/main/java/reactor/filter/Filter.java       |   43 -
 .../src/main/java/reactor/filter/FirstFilter.java  |   38 -
 .../java/reactor/filter/PassThroughFilter.java     |   34 -
 .../src/main/java/reactor/filter/RandomFilter.java |   41 -
 .../main/java/reactor/filter/RoundRobinFilter.java |   82 -
 .../reactor/filter/TraceableDelegatingFilter.java  |   36 -
 .../src/main/java/reactor/filter/package-info.java |    4 -
 .../src/main/java/reactor/fn/BiConsumer.java       |   30 +
 .../src/main/java/reactor/fn/BiFunction.java       |   33 +
 .../src/main/java/reactor/fn/Consumer.java         |   36 +
 .../src/main/java/reactor/fn/Function.java         |   40 +
 .../src/main/java/reactor/fn/Functions.java        |  210 ++
 .../src/main/java/reactor/fn/Pausable.java         |   46 +
 .../src/main/java/reactor/fn/Predicate.java        |   39 +
 .../src/main/java/reactor/fn/Predicates.java       |  152 +
 .../src/main/java/reactor/fn/Resource.java         |   60 +
 .../src/main/java/reactor/fn/Supplier.java         |   36 +
 .../src/main/java/reactor/fn/Suppliers.java        |  227 ++
 .../src/main/java/reactor/fn/package-info.java     |   23 +
 .../src/main/java/reactor/fn/support/Tap.java      |   60 +
 .../main/java/reactor/fn/timer/HashWheelTimer.java |  495 +++
 .../src/main/java/reactor/fn/timer/TimeUtils.java  |   69 +
 .../src/main/java/reactor/fn/timer/Timer.java      |  115 +
 .../src/main/java/reactor/fn/tuple/Tuple.java      |  281 ++
 .../src/main/java/reactor/fn/tuple/Tuple1.java     |   92 +
 .../src/main/java/reactor/fn/tuple/Tuple2.java     |  100 +
 .../src/main/java/reactor/fn/tuple/Tuple3.java     |  102 +
 .../src/main/java/reactor/fn/tuple/Tuple4.java     |  104 +
 .../src/main/java/reactor/fn/tuple/Tuple5.java     |  112 +
 .../src/main/java/reactor/fn/tuple/Tuple6.java     |  113 +
 .../src/main/java/reactor/fn/tuple/Tuple7.java     |  117 +
 .../src/main/java/reactor/fn/tuple/Tuple8.java     |  119 +
 .../src/main/java/reactor/fn/tuple/TupleN.java     |  142 +
 .../main/java/reactor/fn/tuple/package-info.java   |   20 +
 .../src/main/java/reactor/function/Consumer.java   |   36 -
 .../src/main/java/reactor/function/Fn.java         |   28 -
 .../src/main/java/reactor/function/Function.java   |   40 -
 .../src/main/java/reactor/function/Functions.java  |  192 --
 .../src/main/java/reactor/function/Predicate.java  |   39 -
 .../src/main/java/reactor/function/Predicates.java |  104 -
 .../src/main/java/reactor/function/Supplier.java   |   36 -
 .../src/main/java/reactor/function/Suppliers.java  |  214 --
 .../java/reactor/function/batch/BatchConsumer.java |   22 -
 .../java/reactor/function/batch/package-info.java  |    4 -
 .../main/java/reactor/function/package-info.java   |    7 -
 .../java/reactor/function/support/Boundary.java    |  119 -
 .../function/support/CancelConsumerException.java  |   21 -
 .../function/support/DelegatingConsumer.java       |  210 --
 .../main/java/reactor/function/support/Poller.java |  124 -
 .../java/reactor/function/support/Resequencer.java |   94 -
 .../function/support/SingleUseConsumer.java        |   90 -
 .../main/java/reactor/function/support/Tap.java    |   60 -
 .../java/reactor/function/support/UriUtils.java    |  495 ---
 reactor-core/src/main/java/reactor/io/Buffer.java  | 1534 ----------
 .../src/main/java/reactor/io/BufferAllocator.java  |   66 -
 reactor-core/src/main/java/reactor/io/IO.java      |  219 ++
 .../src/main/java/reactor/io/buffer/Buffer.java    | 1438 +++++++++
 .../main/java/reactor/io/codec/BufferCodec.java    |  156 +
 .../main/java/reactor/io/codec/ByteArrayCodec.java |   54 +
 .../src/main/java/reactor/io/codec/Codec.java      |  220 ++
 .../main/java/reactor/io/codec/DelimitedCodec.java |  122 +
 .../src/main/java/reactor/io/codec/Frame.java      |   42 +
 .../src/main/java/reactor/io/codec/FrameCodec.java |  163 +
 .../reactor/io/codec/JavaSerializationCodec.java   |   80 +
 .../java/reactor/io/codec/LengthFieldCodec.java    |  152 +
 .../java/reactor/io/codec/PassThroughCodec.java    |   74 +
 .../java/reactor/io/codec/SerializationCodec.java  |  160 +
 .../main/java/reactor/io/codec/StandardCodecs.java |   54 +
 .../main/java/reactor/io/codec/StringCodec.java    |  140 +
 .../io/codec/compress/CompressionCodec.java        |   87 +
 .../java/reactor/io/codec/compress/GzipCodec.java  |   47 +
 .../reactor/io/codec/compress/SnappyCodec.java     |   47 +
 .../reactor/io/codec/json/JacksonJsonCodec.java    |   76 +
 .../main/java/reactor/io/codec/json/JsonCodec.java |  130 +
 .../java/reactor/io/codec/json/package-info.java   |   20 +
 .../main/java/reactor/io/codec/kryo/KryoCodec.java |   71 +
 .../java/reactor/io/codec/kryo/KryoPoolCodec.java  |   91 +
 .../main/java/reactor/io/codec/package-info.java   |   20 +
 .../reactor/io/codec/protobuf/ProtobufCodec.java   |   91 +
 .../java/reactor/io/encoding/ByteArrayCodec.java   |   58 -
 .../src/main/java/reactor/io/encoding/Codec.java   |   53 -
 .../java/reactor/io/encoding/DelimitedCodec.java   |  134 -
 .../src/main/java/reactor/io/encoding/Frame.java   |   26 -
 .../main/java/reactor/io/encoding/FrameCodec.java  |  155 -
 .../io/encoding/JavaSerializationCodec.java        |   72 -
 .../java/reactor/io/encoding/LengthFieldCodec.java |  166 -
 .../java/reactor/io/encoding/PassThroughCodec.java |   64 -
 .../reactor/io/encoding/SerializationCodec.java    |  143 -
 .../java/reactor/io/encoding/StandardCodecs.java   |   49 -
 .../main/java/reactor/io/encoding/StringCodec.java |   86 -
 .../io/encoding/compress/CompressionCodec.java     |   74 -
 .../reactor/io/encoding/compress/GzipCodec.java    |   31 -
 .../reactor/io/encoding/compress/SnappyCodec.java  |   31 -
 .../reactor/io/encoding/json/JacksonJsonCodec.java |   60 -
 .../java/reactor/io/encoding/json/JsonCodec.java   |  128 -
 .../reactor/io/encoding/json/package-info.java     |    4 -
 .../java/reactor/io/encoding/kryo/KryoCodec.java   |   55 -
 .../java/reactor/io/encoding/package-info.java     |    4 -
 .../io/encoding/protobuf/ProtobufCodec.java        |   75 -
 .../src/main/java/reactor/io/package-info.java     |   16 +
 .../reactor/io/queue/ChronicleQueuePersistor.java  |  262 ++
 .../reactor/io/queue/InMemoryQueuePersistor.java   |   95 +
 .../java/reactor/io/queue/PersistentQueue.java     |   95 +
 .../main/java/reactor/io/queue/QueuePersistor.java |   92 +
 .../main/java/reactor/io/queue/package-info.java   |   21 +
 .../reactor/io/queue/spec/PersistentQueueSpec.java |   96 +
 .../java/reactor/io/queue/spec/package-info.java   |   21 +
 .../java/reactor/io/selector/JsonPathSelector.java |  295 --
 .../src/main/java/reactor/pool/LoadingPool.java    |   83 -
 reactor-core/src/main/java/reactor/pool/Pool.java  |   47 -
 .../java/reactor/queue/BlockingQueueFactory.java   |   57 -
 .../java/reactor/queue/InMemoryQueuePersistor.java |  115 -
 .../queue/IndexedChronicleQueuePersistor.java      |  264 --
 .../main/java/reactor/queue/PersistentQueue.java   |   82 -
 .../main/java/reactor/queue/QueuePersistor.java    |   83 -
 .../src/main/java/reactor/queue/package-info.java  |    5 -
 .../reactor/queue/spec/PersistentQueueSpec.java    |   88 -
 .../main/java/reactor/queue/spec/package-info.java |    5 -
 .../main/java/reactor/support/Identifiable.java    |   12 -
 .../reactor/support/NamedDaemonThreadFactory.java  |   90 -
 .../src/main/java/reactor/support/Supports.java    |   39 -
 .../main/java/reactor/timer/HashWheelTimer.java    |  490 ---
 .../java/reactor/timer/SimpleHashWheelTimer.java   |  196 --
 .../src/main/java/reactor/timer/TimeUtils.java     |   43 -
 .../src/main/java/reactor/timer/Timer.java         |   98 -
 .../src/main/java/reactor/tuple/Tuple.java         |  303 --
 .../src/main/java/reactor/tuple/Tuple1.java        |   44 -
 .../src/main/java/reactor/tuple/Tuple2.java        |   45 -
 .../src/main/java/reactor/tuple/Tuple3.java        |   46 -
 .../src/main/java/reactor/tuple/Tuple4.java        |   47 -
 .../src/main/java/reactor/tuple/Tuple5.java        |   48 -
 .../src/main/java/reactor/tuple/Tuple6.java        |   49 -
 .../src/main/java/reactor/tuple/Tuple7.java        |   50 -
 .../src/main/java/reactor/tuple/Tuple8.java        |   51 -
 .../src/main/java/reactor/tuple/TupleN.java        |   52 -
 .../src/main/java/reactor/tuple/package-info.java  |    4 -
 .../src/main/java/reactor/util/Assert.java         |  403 ---
 .../main/java/reactor/util/CollectionUtils.java    |  530 ----
 .../src/main/java/reactor/util/IoUtils.java        |   51 -
 .../reactor/util/LinkedCaseInsensitiveMap.java     |  154 -
 .../java/reactor/util/LinkedMultiValueMap.java     |  193 --
 .../src/main/java/reactor/util/MultiValueMap.java  |   65 -
 .../src/main/java/reactor/util/ObjectUtils.java    |  995 ------
 .../reactor/util/PartitionedReferencePile.java     |  134 -
 .../src/main/java/reactor/util/StringUtils.java    | 1216 --------
 .../src/main/java/reactor/util/TypeReference.java  |    9 -
 .../src/main/java/reactor/util/TypeUtils.java      |   22 -
 .../src/main/java/reactor/util/UUIDUtils.java      |  111 -
 .../resources/META-INF/reactor/default.properties  |   55 -
 .../reactor/reactor-environment.properties         |   55 +
 .../src/test/groovy/reactor/EnvironmentSpec.groovy |   78 +
 .../src/test/groovy/reactor/GroovyTestUtils.java   |  134 -
 .../groovy/reactor/alloc/AllocatorsSpec.groovy     |  107 -
 .../reactor/alloc/FactoryAllocatorSpec.groovy      |   41 -
 .../test/groovy/reactor/core/BoundarySpec.groovy   |   45 -
 .../groovy/reactor/core/EnvironmentSpec.groovy     |   45 -
 .../src/test/groovy/reactor/core/PollerSpec.groovy |   74 -
 .../test/groovy/reactor/core/ProcessorsSpec.groovy |  172 ++
 .../test/groovy/reactor/core/ReactorsSpec.groovy   |  491 ---
 .../groovy/reactor/core/ResequencersSpec.groovy    |   35 -
 .../core/composable/spec/PromisesSpec.groovy       |  812 -----
 .../core/composable/spec/StreamsSpec.groovy        | 1104 -------
 .../PropertiesConfigurationReaderSpec.groovy       |  210 ++
 .../PropertiesConfigurationReaderSpec.groovy       |  211 --
 .../reactor/core/dispatch/DispatcherSpec.groovy    |  205 ++
 .../reactor/core/fork/ForkJoinPoolSpec.groovy      |   68 -
 .../reactor/core/processor/ProcessorsSpec.groovy   |  101 -
 .../reactor/core/spec/ComponentSpecSpec.groovy     |   90 -
 .../ConsumerFilteringEventRouterSpec.groovy        |  159 -
 .../groovy/reactor/dispatch/DispatcherSpec.groovy  |  199 --
 .../test/groovy/reactor/event/HeadersSpec.groovy   |  148 -
 .../test/groovy/reactor/event/SelectorSpec.groovy  |  262 --
 .../groovy/reactor/filter/FirstFilterSpec.groovy   |   59 -
 .../reactor/filter/PassThroughFilterSpec.groovy    |   49 -
 .../groovy/reactor/filter/RandomFilterSpec.groovy  |   61 -
 .../reactor/filter/RoundRobinFilterSpec.groovy     |   98 -
 .../fn/timer/HashWheelTimerBusySpinStrategy.groovy |   70 +
 .../timer/HashWheelTimerSleepWaitStrategy.groovy   |   69 +
 .../fn/timer/HashWheelTimerYieldingStrategy.groovy |   72 +
 .../src/test/groovy/reactor/io/BufferSpec.groovy   |  419 ---
 .../groovy/reactor/io/buffer/BufferSpec.groovy     |  488 +++
 .../reactor/io/codec/StandardCodecsSpec.groovy     |  126 +
 .../io/codec/compress/CompressionCodecsSpec.groovy |   52 +
 .../io/codec/json/JacksonJsonCodecSpec.groovy      |   42 +
 .../reactor/io/codec/json/JsonCodecSpec.groovy     |   40 +
 .../reactor/io/codec/kryo/KryoCodecSpec.groovy     |   57 +
 .../io/codec/protobuf/ProtobufCodecSpec.groovy     |   43 +
 .../reactor/io/codec/protobuf/TestObjects.java     |  709 +++++
 .../reactor/io/codec/protobuf/test_objects.proto   |    7 +
 .../reactor/io/encoding/StandardCodecsSpec.groovy  |  126 -
 .../encoding/compress/CompressionCodecsSpec.groovy |   52 -
 .../io/encoding/json/JacksonJsonCodecSpec.groovy   |   42 -
 .../reactor/io/encoding/json/JsonCodecSpec.groovy  |   41 -
 .../reactor/io/encoding/kryo/KryoCodecSpec.groovy  |   57 -
 .../io/encoding/protobuf/ProtobufCodecSpec.groovy  |   43 -
 .../reactor/io/encoding/protobuf/TestObjects.java  |  707 -----
 .../io/encoding/protobuf/test_objects.proto        |    7 -
 .../reactor/io/queue/PersistentQueueSpec.groovy    |  123 +
 .../reactor/io/queue/QueuePersistorSpec.groovy     |   97 +
 .../reactor/queue/PersistentQueueSpec.groovy       |  118 -
 .../groovy/reactor/queue/QueuePersistorSpec.groovy |   94 -
 .../timer/HashWheelTimerBusySpinStrategy.groovy    |   70 -
 .../timer/HashWheelTimerSleepWaitStrategy.groovy   |   69 -
 .../timer/HashWheelTimerYieldingStrategy.groovy    |   72 -
 .../reactor/timer/SimpleHashWheelTimerSpec.groovy  |   70 -
 .../test/java/reactor/AbstractPerformanceTest.java |   84 -
 .../src/test/java/reactor/AbstractReactorTest.java |   12 +-
 .../test/java/reactor/alloc/AllocationTests.java   |   67 -
 .../java/reactor/alloc/EventAllocatorTests.java    |   24 -
 .../ConstructorParameterConverterTests.java        |   64 -
 .../src/test/java/reactor/core/AwaitTests.java     |   73 -
 .../test/java/reactor/core/EnvironmentTest.java    |   21 -
 .../reactor/core/composable/ComposableTests.java   |  458 ---
 .../core/dispatch/RingBufferDispatcherTest.java    |   18 +
 .../core/dynamic/DynamicReactorFactoryTests.java   |   59 -
 .../test/java/reactor/core/dynamic/MyReactor.java  |   38 -
 .../java/reactor/core/fork/ForkJoinPoolTests.java  |   71 -
 .../core/processor/AbstractProcessorTests.java     |   90 +
 .../core/processor/ConsistentProcessorTests.java   |  239 ++
 .../core/processor/ProcessorThroughputTests.java   |  147 -
 .../core/processor/PublisherFactoryTests.java      |   74 +
 .../processor/ReactorProcessorGettersTests.java    |   36 +
 .../core/processor/RingBufferProcessorTests.java   |   31 +
 .../processor/RingBufferWorkProcessorTests.java    |   93 +
 .../core/processor/SubscriberFactoryTests.java     |   87 +
 .../java/reactor/core/support/UUIDUtilsTests.java  |  250 ++
 .../java/reactor/event/CachingAlgorithmTests.java  |  168 -
 .../java/reactor/event/CachingRegistryTests.java   |  219 --
 .../test/java/reactor/event/SelectorUnitTests.java |  190 --
 .../src/test/java/reactor/fn/timer/TimerTests.java |   64 +
 .../src/test/java/reactor/fn/tuple/TupleTests.java |   83 +
 .../function/support/DelegatingConsumerTest.java   |   63 -
 .../test/java/reactor/io/buffer/BufferTests.java   |   31 +
 .../src/test/java/reactor/tuple/TupleTests.java    |   63 -
 .../src/test/java/reactor/util/AssertTests.java    |  176 --
 .../java/reactor/util/CollectionUtilsTests.java    |  243 --
 .../util/LinkedCaseInsensitiveMapTests.java        |   58 -
 .../reactor/util/LinkedMultiValueMapTests.java     |   84 -
 .../test/java/reactor/util/ObjectUtilsTests.java   |  575 ----
 .../util/PartitionedReferencePileTests.java        |  136 -
 .../test/java/reactor/util/StringUtilsTests.java   |  649 ----
 .../src/test/java/reactor/util/UUIDUtilsTests.java |  250 --
 .../resources/META-INF/reactor/custom.properties   |    2 +-
 .../META-INF/reactor/override-custom.properties    |    2 +-
 .../META-INF/reactor/override-default.properties   |    4 +-
 .../META-INF/reactor/unrecognized-type.properties  |    2 +-
 reactor-core/src/test/resources/logback.xml        |    5 +-
 .../groovy/reactor/groovy/ext/BusExtensions.groovy |  142 +
 .../reactor/groovy/ext/ComposableExtensions.groovy |  240 --
 .../reactor/groovy/ext/ObservableExtensions.groovy |  147 -
 .../reactor/groovy/ext/ProcessorExtensions.groovy  |   49 -
 .../groovy/ext/ReactorStaticExtensions.groovy      |   24 +-
 .../reactor/groovy/ext/StreamExtensions.groovy     |  109 +
 .../reactor/groovy/support/ClosureConsumer.groovy  |    4 +-
 .../groovy/support/ClosureEventConsumer.groovy     |   21 +-
 .../groovy/support/ClosureEventFunction.groovy     |    6 +-
 .../reactor/groovy/support/ClosureFunction.groovy  |    4 +-
 .../reactor/groovy/support/ClosurePredicate.groovy |    4 +-
 .../reactor/groovy/support/ClosureReduce.groovy    |    6 +-
 .../reactor/groovy/support/ClosureSupplier.groovy  |    4 +-
 .../groovy/support/ClosureTupleConsumer.java       |    6 +-
 .../config/DispatcherConfigurationBuilder.groovy   |    6 +-
 .../groovy/config/EnvironmentBuilder.groovy        |   26 +-
 .../reactor/groovy/config/GroovyEnvironment.groovy |   28 +-
 .../reactor/groovy/config/ReactorBuilder.groovy    |  194 +-
 .../reactor/groovy/config/StreamEventRouter.java   |   90 -
 .../java/reactor/groovy/config/StreamRouter.java   |   65 +
 .../org.codehaus.groovy.runtime.ExtensionModule    |    5 +-
 .../groovy/reactor/groovy/CompileStaticTest.groovy |    6 +-
 .../reactor/groovy/GroovyConfigurationSpec.groovy  |   10 +-
 .../reactor/groovy/GroovyEventBusSpec.groovy       |  160 +
 .../reactor/groovy/GroovyPromisesSpec.groovy       |  102 +-
 .../groovy/reactor/groovy/GroovyReactorSpec.groovy |  164 -
 .../groovy/reactor/groovy/GroovyStreamSpec.groovy  |  180 +-
 .../reactor/groovy/StaticConfiguration.groovy      |   45 +-
 reactor-logback/README.md                          |   11 +-
 .../main/java/reactor/logback/AsyncAppender.java   |  116 +-
 .../java/reactor/logback/DurableAsyncAppender.java |   24 +-
 .../java/reactor/logback/DurableLogUtility.java    |   21 +-
 .../java/reactor/logback/LoggingEventRecord.java   |   16 +
 .../src/test/java/reactor/dummy/Test.java          |    2 +-
 .../java/reactor/logback/AsyncAppenderTests.java   |    4 +-
 reactor-logback/src/test/resources/logback.xml     |    2 +-
 .../main/java/reactor/io/net/ChannelStream.java    |  161 +
 .../src/main/java/reactor/io/net/NetSelectors.java |  127 +
 .../src/main/java/reactor/io/net/NetStreams.java   |  980 ++++++
 .../main/java/reactor/io/net/ReactorChannel.java   |  103 +
 .../java/reactor/io/net/ReactorChannelHandler.java |   36 +
 .../main/java/reactor/io/net/ReactorClient.java    |   74 +
 .../src/main/java/reactor/io/net/ReactorPeer.java  |  127 +
 .../src/main/java/reactor/io/net/Reconnect.java    |   45 +
 reactor-net/src/main/java/reactor/io/net/Spec.java |  843 ++++++
 .../reactor/io/net/codec/syslog/SyslogCodec.java   |  248 ++
 .../reactor/io/net/codec/syslog/SyslogMessage.java |  122 +
 .../reactor/io/net/codec/syslog/package-info.java  |   20 +
 .../reactor/io/net/config/ClientSocketOptions.java |   23 +
 .../reactor/io/net/config/CommonSocketOptions.java |  182 ++
 .../reactor/io/net/config/ServerSocketOptions.java |   93 +
 .../java/reactor/io/net/config/SslOptions.java     |  117 +
 .../java/reactor/io/net/config/package-info.java   |   20 +
 .../main/java/reactor/io/net/http/HttpChannel.java |  253 ++
 .../main/java/reactor/io/net/http/HttpClient.java  |  174 ++
 .../java/reactor/io/net/http/HttpException.java    |   38 +
 .../java/reactor/io/net/http/HttpSelector.java     |   74 +
 .../main/java/reactor/io/net/http/HttpServer.java  |  229 ++
 .../java/reactor/io/net/http/model/Headers.java    |   67 +
 .../reactor/io/net/http/model/HttpHeaders.java     |  152 +
 .../java/reactor/io/net/http/model/Method.java     |   74 +
 .../java/reactor/io/net/http/model/Protocol.java   |   45 +
 .../reactor/io/net/http/model/ReadableHeaders.java |   50 +
 .../reactor/io/net/http/model/ResponseHeaders.java |  143 +
 .../java/reactor/io/net/http/model/Status.java     |  523 ++++
 .../java/reactor/io/net/http/model/Transfer.java   |   59 +
 .../reactor/io/net/http/model/WritableHeaders.java |   58 +
 .../java/reactor/io/net/http/package-info.java     |   20 +
 .../net/impl/netty/NettyChannelHandlerBridge.java  |  562 ++++
 .../io/net/impl/netty/NettyChannelStream.java      |  189 ++
 .../net/impl/netty/NettyClientSocketOptions.java   |   52 +
 .../io/net/impl/netty/NettyNativeDetector.java     |   62 +
 .../net/impl/netty/NettyServerSocketOptions.java   |   52 +
 .../io/net/impl/netty/http/NettyHttpChannel.java   |  230 ++
 .../io/net/impl/netty/http/NettyHttpClient.java    |  272 ++
 .../impl/netty/http/NettyHttpClientHandler.java    |  216 ++
 .../io/net/impl/netty/http/NettyHttpHeaders.java   |  190 ++
 .../impl/netty/http/NettyHttpResponseHeaders.java  |  197 ++
 .../io/net/impl/netty/http/NettyHttpServer.java    |  168 +
 .../impl/netty/http/NettyHttpServerHandler.java    |  154 +
 .../impl/netty/http/NettyHttpWSClientHandler.java  |  146 +
 .../impl/netty/http/NettyHttpWSServerHandler.java  |   90 +
 .../reactor/io/net/impl/netty/package-info.java    |   22 +
 .../io/net/impl/netty/tcp/NettyTcpClient.java      |  358 +++
 .../io/net/impl/netty/tcp/NettyTcpServer.java      |  219 ++
 .../io/net/impl/netty/udp/NettyDatagramServer.java |  319 ++
 .../io/net/impl/zmq/ZeroMQChannelStream.java       |  250 ++
 .../io/net/impl/zmq/ZeroMQClientSocketOptions.java |  113 +
 .../io/net/impl/zmq/ZeroMQServerSocketOptions.java |  115 +
 .../java/reactor/io/net/impl/zmq/ZeroMQWorker.java |  130 +
 .../java/reactor/io/net/impl/zmq/tcp/ZeroMQ.java   |  227 ++
 .../io/net/impl/zmq/tcp/ZeroMQTcpClient.java       |  211 ++
 .../io/net/impl/zmq/tcp/ZeroMQTcpServer.java       |  233 ++
 .../src/main/java/reactor/io/net/package-info.java |   24 +
 .../main/java/reactor/io/net/tcp/TcpClient.java    |   99 +
 .../main/java/reactor/io/net/tcp/TcpServer.java    |   89 +
 .../main/java/reactor/io/net/tcp/package-info.java |   20 +
 .../reactor/io/net/tcp/ssl/SSLEngineSupplier.java  |   74 +
 .../java/reactor/io/net/tcp/ssl/package-info.java  |   20 +
 .../reactor/io/net/tcp/support/SocketUtils.java    |  378 +++
 .../java/reactor/io/net/udp/DatagramServer.java    |  130 +
 .../main/java/reactor/net/AbstractNetChannel.java  |  326 --
 .../src/main/java/reactor/net/AbstractNetPeer.java |  260 --
 .../src/main/java/reactor/net/NetChannel.java      |  171 --
 .../src/main/java/reactor/net/NetClient.java       |   47 -
 .../src/main/java/reactor/net/NetServer.java       |   40 -
 .../src/main/java/reactor/net/Reconnect.java       |   29 -
 .../reactor/net/config/ClientSocketOptions.java    |   23 -
 .../reactor/net/config/CommonSocketOptions.java    |  165 -
 .../reactor/net/config/ServerSocketOptions.java    |   70 -
 .../main/java/reactor/net/config/SslOptions.java   |  101 -
 .../main/java/reactor/net/config/package-info.java |    4 -
 .../reactor/net/encoding/syslog/SyslogCodec.java   |  254 --
 .../reactor/net/encoding/syslog/SyslogMessage.java |  122 -
 .../reactor/net/encoding/syslog/package-info.java  |    4 -
 .../net/netty/NettyClientSocketOptions.java        |   34 -
 .../net/netty/NettyEventLoopDispatcher.java        |   82 -
 .../java/reactor/net/netty/NettyNetChannel.java    |  161 -
 .../net/netty/NettyNetChannelInboundHandler.java   |  109 -
 .../net/netty/NettyNetChannelOutboundHandler.java  |   28 -
 .../net/netty/NettyServerSocketOptions.java        |   36 -
 .../main/java/reactor/net/netty/package-info.java  |    6 -
 .../java/reactor/net/netty/tcp/NettyTcpClient.java |  390 ---
 .../java/reactor/net/netty/tcp/NettyTcpServer.java |  213 --
 .../reactor/net/netty/udp/NettyDatagramServer.java |  302 --
 .../main/java/reactor/net/spec/NetServerSpec.java  |  150 -
 .../src/main/java/reactor/net/tcp/TcpClient.java   |  120 -
 .../src/main/java/reactor/net/tcp/TcpServer.java   |  125 -
 .../main/java/reactor/net/tcp/package-info.java    |    4 -
 .../tcp/spec/IncrementalBackoffReconnectSpec.java  |  159 -
 .../java/reactor/net/tcp/spec/TcpClientSpec.java   |  189 --
 .../main/java/reactor/net/tcp/spec/TcpClients.java |   58 -
 .../java/reactor/net/tcp/spec/TcpServerSpec.java   |   92 -
 .../main/java/reactor/net/tcp/spec/TcpServers.java |   61 -
 .../java/reactor/net/tcp/spec/package-info.java    |    5 -
 .../reactor/net/tcp/ssl/SSLEngineSupplier.java     |   54 -
 .../java/reactor/net/tcp/ssl/package-info.java     |    4 -
 .../java/reactor/net/tcp/support/SocketUtils.java  |  378 ---
 .../main/java/reactor/net/udp/DatagramServer.java  |  168 -
 .../reactor/net/udp/spec/DatagramServerSpec.java   |   76 -
 .../java/reactor/net/udp/spec/DatagramServers.java |   56 -
 .../reactor/net/zmq/ZeroMQClientSocketOptions.java |   97 -
 .../java/reactor/net/zmq/ZeroMQNetChannel.java     |  165 -
 .../reactor/net/zmq/ZeroMQServerSocketOptions.java |   99 -
 .../main/java/reactor/net/zmq/ZeroMQWorker.java    |  114 -
 .../src/main/java/reactor/net/zmq/tcp/ZeroMQ.java  |  191 --
 .../java/reactor/net/zmq/tcp/ZeroMQTcpClient.java  |  187 --
 .../java/reactor/net/zmq/tcp/ZeroMQTcpServer.java  |  152 -
 .../HttpResponseStatusCodesHandlingSpec.groovy     |   83 +
 .../groovy/reactor/io/net/http/HttpSpec.groovy     |  177 ++
 .../io/net/tcp/encoding/SyslogCodecSpec.groovy     |   26 +
 .../io/net/tcp/netty/NettyTcpServerSpec.groovy     |  253 ++
 .../net/tcp/encoding/SyslogCodecSpec.groovy        |   26 -
 .../tcp/netty/ClientServerIntegrationSpec.groovy   |  162 -
 .../net/tcp/netty/NettyTcpServerSpec.groovy        |  167 -
 .../io/net/AbstractNetClientServerTest.java        |  223 ++
 .../java/reactor/io/net/http/PostAndGetTests.java  |  132 +
 .../reactor/io/net/tcp/ClientServerHttpTests.java  |  354 +++
 .../net/tcp/IncrementalBackoffReconnectTest.java   |   81 +
 .../test/java/reactor/io/net/tcp/SmokeTests.java   |  596 ++++
 .../test/java/reactor/io/net/tcp/SpeedTests.java   |  164 +
 .../java/reactor/io/net/tcp/TcpClientTests.java    |  571 ++++
 .../java/reactor/io/net/tcp/TcpServerTests.java    |  724 +++++
 .../io/net/tcp/ZeroMQClientServerTests.java        |  138 +
 .../io/net/tcp/syslog/SyslogTcpServerTests.java    |  227 ++
 .../io/net/tcp/syslog/hdfs/HdfsConsumer.java       |   56 +
 .../reactor/io/net/tcp/syslog/test/Severity.java   |   27 +
 .../io/net/tcp/syslog/test/SyslogCodec.java        |   62 +
 .../io/net/tcp/syslog/test/SyslogMessage.java      |   87 +
 .../net/tcp/syslog/test/SyslogMessageParser.java   |   74 +
 .../reactor/io/net/tcp/syslog/test/Timestamp.java  |   81 +
 .../java/reactor/io/net/udp/UdpServerTests.java    |  200 ++
 .../reactor/net/AbstractNetClientServerTest.java   |  259 --
 .../net/tcp/IncrementalBackoffReconnectTest.java   |   82 -
 .../src/test/java/reactor/net/tcp/SpeedTests.java  |  164 -
 .../test/java/reactor/net/tcp/TcpClientTests.java  |  591 ----
 .../test/java/reactor/net/tcp/TcpServerTests.java  |  674 -----
 .../reactor/net/tcp/ZeroMQClientServerTests.java   |  133 -
 .../net/tcp/syslog/SyslogTcpServerTests.java       |  233 --
 .../reactor/net/tcp/syslog/hdfs/HdfsConsumer.java  |   56 -
 .../java/reactor/net/tcp/syslog/test/Severity.java |   27 -
 .../reactor/net/tcp/syslog/test/SyslogCodec.java   |   62 -
 .../reactor/net/tcp/syslog/test/SyslogMessage.java |   87 -
 .../net/tcp/syslog/test/SyslogMessageParser.java   |   74 -
 .../reactor/net/tcp/syslog/test/Timestamp.java     |   81 -
 .../test/java/reactor/net/udp/UdpServerTests.java  |  174 --
 .../resources/META-INF/reactor/default.properties  |   54 -
 .../reactor/reactor-environment.properties         |   50 +
 reactor-net/src/test/resources/logback.xml         |   36 +
 .../src/main/java/reactor/rx/BiStreams.java        |  167 +
 .../src/main/java/reactor/rx/IOStreams.java        |  139 +
 .../src/main/java/reactor/rx/Promise.java          |  745 +++++
 .../src/main/java/reactor/rx/Promises.java         |  444 +++
 .../src/main/java/reactor/rx/Stream.java           | 3193 ++++++++++++++++++++
 .../src/main/java/reactor/rx/StreamUtils.java      |  393 +++
 .../src/main/java/reactor/rx/Streams.java          | 1920 ++++++++++++
 .../src/main/java/reactor/rx/action/Action.java    |  703 +++++
 .../java/reactor/rx/action/CompositeAction.java    |  105 +
 .../src/main/java/reactor/rx/action/Control.java   |   57 +
 .../src/main/java/reactor/rx/action/Signal.java    |  270 ++
 .../reactor/rx/action/aggregation/BatchAction.java |  157 +
 .../rx/action/aggregation/BufferAction.java        |   61 +
 .../rx/action/aggregation/BufferShiftAction.java   |  169 ++
 .../action/aggregation/BufferShiftWhenAction.java  |  157 +
 .../rx/action/aggregation/BufferWhenAction.java    |  119 +
 .../reactor/rx/action/aggregation/CacheAction.java |  151 +
 .../reactor/rx/action/aggregation/LastAction.java  |   41 +
 .../rx/action/aggregation/SampleAction.java        |   68 +
 .../reactor/rx/action/aggregation/SortAction.java  |   56 +
 .../rx/action/aggregation/WindowAction.java        |  107 +
 .../rx/action/aggregation/WindowShiftAction.java   |  181 ++
 .../action/aggregation/WindowShiftWhenAction.java  |  200 ++
 .../rx/action/aggregation/WindowWhenAction.java    |  146 +
 .../rx/action/combination/CombineLatestAction.java |  187 ++
 .../rx/action/combination/ConcatAction.java        |  221 ++
 .../rx/action/combination/DynamicMergeAction.java  |  151 +
 .../reactor/rx/action/combination/FanInAction.java |  283 ++
 .../rx/action/combination/FanInSubscription.java   |  281 ++
 .../reactor/rx/action/combination/MergeAction.java |   94 +
 .../rx/action/combination/SwitchAction.java        |  231 ++
 .../reactor/rx/action/combination/ZipAction.java   |  306 ++
 .../rx/action/conditional/ExistsAction.java        |   53 +
 .../rx/action/control/DispatcherAction.java        |  173 ++
 .../rx/action/control/FlowControlAction.java       |   74 +
 .../reactor/rx/action/control/RepeatAction.java    |  107 +
 .../rx/action/control/RepeatWhenAction.java        |  159 +
 .../rx/action/control/ThrottleRequestAction.java   |  102 +
 .../action/control/ThrottleRequestWhenAction.java  |  122 +
 .../java/reactor/rx/action/error/ErrorAction.java  |   61 +
 .../reactor/rx/action/error/ErrorReturnAction.java |   57 +
 .../rx/action/error/ErrorWithValueAction.java      |   63 +
 .../reactor/rx/action/error/FallbackAction.java    |   84 +
 .../reactor/rx/action/error/IgnoreErrorAction.java |   54 +
 .../java/reactor/rx/action/error/RetryAction.java  |  116 +
 .../reactor/rx/action/error/RetryWhenAction.java   |  153 +
 .../reactor/rx/action/error/TimeoutAction.java     |   93 +
 .../reactor/rx/action/filter/DistinctAction.java   |   59 +
 .../action/filter/DistinctUntilChangedAction.java  |   50 +
 .../reactor/rx/action/filter/ElementAtAction.java  |   74 +
 .../reactor/rx/action/filter/FilterAction.java     |   51 +
 .../java/reactor/rx/action/filter/SkipAction.java  |   54 +
 .../reactor/rx/action/filter/SkipUntilTimeout.java |   67 +
 .../java/reactor/rx/action/filter/TakeAction.java  |   63 +
 .../reactor/rx/action/filter/TakeUntilTimeout.java |   74 +
 .../reactor/rx/action/filter/TakeWhileAction.java  |   51 +
 .../reactor/rx/action/metrics/CountAction.java     |   72 +
 .../reactor/rx/action/metrics/ElapsedAction.java   |   44 +
 .../reactor/rx/action/metrics/TimestampAction.java |   32 +
 .../main/java/reactor/rx/action/package-info.java  |   21 +
 .../reactor/rx/action/pair/ReduceByKeyAction.java  |   55 +
 .../reactor/rx/action/pair/ScanByKeyAction.java    |  149 +
 .../reactor/rx/action/passive/AfterAction.java     |   41 +
 .../reactor/rx/action/passive/CallbackAction.java  |   49 +
 .../reactor/rx/action/passive/FinallyAction.java   |   51 +
 .../reactor/rx/action/passive/LoggerAction.java    |   93 +
 .../action/passive/StreamStateCallbackAction.java  |   68 +
 .../rx/action/support/DefaultSubscriber.java       |   57 +
 .../reactor/rx/action/support/TapAndControls.java  |   65 +
 .../rx/action/terminal/AdaptiveConsumerAction.java |  221 ++
 .../reactor/rx/action/terminal/ConsumerAction.java |  148 +
 .../transformation/DefaultIfEmptyAction.java       |   47 +
 .../action/transformation/DematerializeAction.java |   38 +
 .../rx/action/transformation/GroupByAction.java    |  181 ++
 .../rx/action/transformation/MapAction.java        |   43 +
 .../action/transformation/MaterializeAction.java   |   41 +
 .../rx/action/transformation/ScanAction.java       |   94 +
 .../rx/action/transformation/SplitAction.java      |   36 +
 .../reactor/rx/broadcast/BehaviorBroadcaster.java  |  313 ++
 .../java/reactor/rx/broadcast/Broadcaster.java     |  292 ++
 .../rx/broadcast/SerializedBroadcaster.java        |  136 +
 .../java/reactor/rx/broadcast/package-info.java    |   22 +
 .../src/main/java/reactor/rx/package-info.java     |   23 +
 .../main/java/reactor/rx/stream/BarrierStream.java |  154 +
 .../java/reactor/rx/stream/DeferredStream.java     |   54 +
 .../main/java/reactor/rx/stream/ErrorStream.java   |   81 +
 .../main/java/reactor/rx/stream/FutureStream.java  |  101 +
 .../main/java/reactor/rx/stream/GroupedStream.java |   47 +
 .../java/reactor/rx/stream/IterableStream.java     |   91 +
 .../main/java/reactor/rx/stream/LiftStream.java    |   95 +
 .../src/main/java/reactor/rx/stream/MapStream.java |  159 +
 .../reactor/rx/stream/PeriodicTimerStream.java     |  104 +
 .../java/reactor/rx/stream/PublisherStream.java    |  101 +
 .../main/java/reactor/rx/stream/RangeStream.java   |  111 +
 .../java/reactor/rx/stream/SingleTimerStream.java  |  101 +
 .../java/reactor/rx/stream/SingleValueStream.java  |   87 +
 .../java/reactor/rx/stream/SupplierStream.java     |   92 +
 .../rx/stream/io/ChronicleReaderStream.java        |  370 +++
 .../java/reactor/rx/stream/io/ChronicleStream.java |  170 ++
 .../java/reactor/rx/stream/io/package-info.java    |   20 +
 .../reactor/rx/subscription/BatchSubscription.java |   50 +
 .../reactor/rx/subscription/DropSubscription.java  |   73 +
 .../rx/subscription/FanOutSubscription.java        |  171 ++
 .../reactor/rx/subscription/PushSubscription.java  |  223 ++
 .../rx/subscription/ReactiveSubscription.java      |  296 ++
 .../subscription/support/WrappedSubscription.java  |  123 +
 .../groovy/reactor/rx/ChronicleStreamSpec.groovy   |  113 +
 .../src/test/groovy/reactor/rx/PromisesSpec.groovy |  830 +++++
 .../src/test/groovy/reactor/rx/StreamsSpec.groovy  | 3039 +++++++++++++++++++
 .../src/test/java/reactor/AbstractReactorTest.java |   47 +
 .../tck/StreamIdentityProcessorTests.java          |  281 ++
 .../src/test/java/reactor/rx/AwaitTests.java       |   96 +
 .../src/test/java/reactor/rx/FizzBuzzTests.java    |  121 +
 .../src/test/java/reactor/rx/PopularTagTests.java  |  100 +
 .../java/reactor/rx/StreamCombinationTests.java    |  339 +++
 .../src/test/java/reactor/rx/StreamTests.java      | 1652 ++++++++++
 .../reactor/reactor-environment.properties         |   55 +
 settings.gradle                                    |    9 +-
 src/docbook/css/highlight.css                      |   35 +
 src/docbook/css/manual-multipage.css               |    9 +
 src/docbook/css/manual-singlepage.css              |    6 +
 src/docbook/css/manual.css                         |  341 +++
 src/docbook/images/background.png                  |  Bin 0 -> 20967 bytes
 src/docbook/images/caution.png                     |  Bin 0 -> 2099 bytes
 src/docbook/images/important.png                   |  Bin 0 -> 2085 bytes
 src/docbook/images/logo.png                        |  Bin 0 -> 20967 bytes
 src/docbook/images/note.png                        |  Bin 0 -> 2257 bytes
 src/docbook/images/tip.png                         |  Bin 0 -> 931 bytes
 src/docbook/images/warning.png                     |  Bin 0 -> 2130 bytes
 src/docbook/xsl/common.xsl                         |   44 +
 src/docbook/xsl/epub.xsl                           |   30 +
 src/docbook/xsl/html-multipage.xsl                 |   73 +
 src/docbook/xsl/html-singlepage.xsl                |   30 +
 src/docbook/xsl/html.xsl                           |  140 +
 src/docbook/xsl/pdf.xsl                            |  608 ++++
 src/docbook/xsl/xslthl-config.xml                  |   23 +
 src/docbook/xsl/xslthl/asciidoc-hl.xml             |   41 +
 src/docbook/xsl/xslthl/bourne-hl.xml               |   95 +
 src/docbook/xsl/xslthl/c-hl.xml                    |  117 +
 src/docbook/xsl/xslthl/cpp-hl.xml                  |  151 +
 src/docbook/xsl/xslthl/csharp-hl.xml               |  194 ++
 src/docbook/xsl/xslthl/css-hl.xml                  |  176 ++
 src/docbook/xsl/xslthl/html-hl.xml                 |  122 +
 src/docbook/xsl/xslthl/ini-hl.xml                  |   45 +
 src/docbook/xsl/xslthl/java-hl.xml                 |  117 +
 src/docbook/xsl/xslthl/javascript-hl.xml           |  147 +
 src/docbook/xsl/xslthl/json-hl.xml                 |   37 +
 src/docbook/xsl/xslthl/perl-hl.xml                 |  120 +
 src/docbook/xsl/xslthl/php-hl.xml                  |  154 +
 src/docbook/xsl/xslthl/properties-hl.xml           |   38 +
 src/docbook/xsl/xslthl/python-hl.xml               |  100 +
 src/docbook/xsl/xslthl/ruby-hl.xml                 |  109 +
 src/docbook/xsl/xslthl/sql2003-hl.xml              |  565 ++++
 src/docbook/xsl/xslthl/yaml-hl.xml                 |   47 +
 src/docs/asciidoc/clojure.adoc                     |    8 +
 src/docs/asciidoc/core-codec.adoc                  |  170 ++
 src/docs/asciidoc/core-processor.adoc              |  130 +
 src/docs/asciidoc/core.adoc                        |  464 +++
 src/docs/asciidoc/event-bus.adoc                   |  118 +
 src/docs/asciidoc/gettingstarted.adoc              |  252 ++
 src/docs/asciidoc/groovy.adoc                      |    7 +
 src/docs/asciidoc/images/RBP.png                   |  Bin 0 -> 801595 bytes
 src/docs/asciidoc/images/RBWP.png                  |  Bin 0 -> 906863 bytes
 src/docs/asciidoc/images/broadcast.png             |  Bin 0 -> 165933 bytes
 src/docs/asciidoc/images/bus-overview.png          |  Bin 0 -> 326766 bytes
 src/docs/asciidoc/images/core-overview.png         |  Bin 0 -> 471980 bytes
 src/docs/asciidoc/images/golo/body-bg.png          |  Bin 0 -> 264510 bytes
 src/docs/asciidoc/images/golo/pre-bg.png           |  Bin 0 -> 301360 bytes
 src/docs/asciidoc/images/logo.png                  |  Bin 0 -> 20967 bytes
 src/docs/asciidoc/images/longMaxThreading.png      |  Bin 0 -> 195787 bytes
 src/docs/asciidoc/images/maker/body-bg.png         |  Bin 0 -> 12255 bytes
 src/docs/asciidoc/images/marble/marble-101.png     |  Bin 0 -> 360054 bytes
 .../images/marble/marble-overflowbuffer.png        |  Bin 0 -> 188114 bytes
 .../asciidoc/images/marble/marble-overflowdrop.png |  Bin 0 -> 158165 bytes
 .../asciidoc/images/marble/marble-requestwhen.png  |  Bin 0 -> 221809 bytes
 .../asciidoc/images/marble/marble-throttle.png     |  Bin 0 -> 161112 bytes
 src/docs/asciidoc/images/modules.png               |  Bin 0 -> 632194 bytes
 src/docs/asciidoc/images/nThreading.png            |  Bin 0 -> 231161 bytes
 src/docs/asciidoc/images/net-latency.png           |  Bin 0 -> 413223 bytes
 src/docs/asciidoc/images/net-overview.png          |  Bin 0 -> 569771 bytes
 src/docs/asciidoc/images/overview.png              |  Bin 0 -> 895804 bytes
 src/docs/asciidoc/images/rbd2.png                  |  Bin 0 -> 461142 bytes
 src/docs/asciidoc/images/rs.png                    |  Bin 0 -> 232137 bytes
 src/docs/asciidoc/images/signals.png               |  Bin 0 -> 21826 bytes
 src/docs/asciidoc/images/streams-overview.png      |  Bin 0 -> 565215 bytes
 src/docs/asciidoc/images/wiringup.png              |  Bin 0 -> 174386 bytes
 src/docs/asciidoc/index-docinfo.html               |   16 +
 src/docs/asciidoc/index-docinfo.xml                |   22 +
 src/docs/asciidoc/index.asciidoc                   |   50 +
 src/docs/asciidoc/nav.html                         |   24 +
 src/docs/asciidoc/net-e2e.adoc                     |    3 +
 src/docs/asciidoc/net-http.adoc                    |   33 +
 src/docs/asciidoc/net-tcp.adoc                     |   23 +
 src/docs/asciidoc/net.adoc                         |  129 +
 src/docs/asciidoc/recipes.adoc                     |  306 ++
 src/docs/asciidoc/spring.adoc                      |   24 +
 src/docs/asciidoc/streams.adoc                     | 2108 +++++++++++++
 src/docs/asciidoc/stylesheets/asciidoctor.css      |  656 ++++
 src/docs/asciidoc/stylesheets/colony.css           |  662 ++++
 src/docs/asciidoc/stylesheets/foundation-lime.css  |  659 ++++
 .../asciidoc/stylesheets/foundation-potion.css     |  659 ++++
 src/docs/asciidoc/stylesheets/foundation.css       |  650 ++++
 src/docs/asciidoc/stylesheets/github.css           |  671 ++++
 src/docs/asciidoc/stylesheets/golo.css             |  687 +++++
 src/docs/asciidoc/stylesheets/iconic.css           |  694 +++++
 src/docs/asciidoc/stylesheets/maker.css            |  670 ++++
 src/docs/asciidoc/stylesheets/readthedocs.css      |  671 ++++
 src/docs/asciidoc/stylesheets/rocket-panda.css     |  664 ++++
 src/docs/asciidoc/stylesheets/rubygems.css         |  652 ++++
 936 files changed, 86625 insertions(+), 47044 deletions(-)

-- 
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-java/projectreactor.git



More information about the pkg-java-commits mailing list