[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