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 <[email protected]> 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 _______________________________________________ pkg-java-commits mailing list [email protected] http://lists.alioth.debian.org/cgi-bin/mailman/listinfo/pkg-java-commits
