[projectreactor] 04/04: Merge tag 'upstream/1.1.6'
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Fri May 27 07:01:50 UTC 2016
This is an automated email from the git hooks/post-receive script.
ebourg-guest pushed a commit to annotated tag debian/1.1.6-1
in repository projectreactor.
commit bb02665a5f56105bbe14b2e20077a85eaebcc8e2
Merge: 50c6aa8 b55768c
Author: Emmanuel Bourg <ebourg at apache.org>
Date: Tue May 24 10:06:37 2016 +0200
Merge tag 'upstream/1.1.6'
Upstream version 1.1.6
.gitignore | 16 +
CHANGELOG.md | 56 +
COMMITLOG.txt | 304 ++++
README.md | 55 +
build.gradle | 374 +++++
gradle.properties | 1 +
gradle/ide.gradle | 109 ++
gradle/setup.gradle | 128 ++
.../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/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 +
.../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 +
.../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 ++
.../src/main/java/reactor/core/package-info.java | 4 +
.../java/reactor/core/processor/Operation.java | 71 +
.../java/reactor/core/processor/Processor.java | 255 ++++
.../java/reactor/core/processor/package-info.java | 5 +
.../reactor/core/processor/spec/ProcessorSpec.java | 173 +++
.../reactor/core/processor/spec/package-info.java | 5 +
.../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 +
.../core/support/DefaultEnvironmentSupplier.java | 25 +
.../java/reactor/core/support/NotifyConsumer.java | 55 +
.../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/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 +
.../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 | 4 +
.../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 +
.../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/ReactorsSpec.groovy | 491 +++++++
.../groovy/reactor/core/ResequencersSpec.groovy | 35 +
.../core/composable/spec/PromisesSpec.groovy | 812 +++++++++++
.../core/composable/spec/StreamsSpec.groovy | 1104 ++++++++++++++
.../PropertiesConfigurationReaderSpec.groovy | 211 +++
.../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 ++
.../src/test/groovy/reactor/io/BufferSpec.groovy | 419 ++++++
.../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/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 | 34 +
.../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/dynamic/DynamicReactorFactoryTests.java | 59 +
.../test/java/reactor/core/dynamic/MyReactor.java | 38 +
.../java/reactor/core/fork/ForkJoinPoolTests.java | 71 +
.../core/processor/ProcessorThroughputTests.java | 147 ++
.../java/reactor/event/CachingAlgorithmTests.java | 168 +++
.../java/reactor/event/CachingRegistryTests.java | 219 +++
.../test/java/reactor/event/SelectorUnitTests.java | 190 +++
.../function/support/DelegatingConsumerTest.java | 63 +
.../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 | 18 +
.../META-INF/reactor/override-custom.properties | 17 +
.../META-INF/reactor/override-default.properties | 17 +
.../META-INF/reactor/unrecognized-type.properties | 18 +
reactor-core/src/test/resources/logback.xml | 33 +
.../reactor/groovy/ext/ComposableExtensions.groovy | 240 +++
.../reactor/groovy/ext/ObservableExtensions.groovy | 147 ++
.../reactor/groovy/ext/ProcessorExtensions.groovy | 49 +
.../groovy/ext/ReactorStaticExtensions.groovy | 55 +
.../reactor/groovy/support/ClosureConsumer.groovy | 39 +
.../groovy/support/ClosureEventConsumer.groovy | 81 ++
.../groovy/support/ClosureEventFunction.groovy | 48 +
.../reactor/groovy/support/ClosureFunction.groovy | 40 +
.../reactor/groovy/support/ClosurePredicate.groovy | 39 +
.../reactor/groovy/support/ClosureReduce.groovy | 45 +
.../reactor/groovy/support/ClosureSupplier.groovy | 39 +
.../main/java/reactor/groovy/ext/package-info.java | 3 +
.../groovy/support/ClosureTupleConsumer.java | 26 +
.../groovy/reactor/groovy/config/DSLUtils.groovy | 27 +
.../config/DispatcherConfigurationBuilder.groovy | 30 +
.../groovy/config/EnvironmentBuilder.groovy | 68 +
.../reactor/groovy/config/GroovyEnvironment.groovy | 185 +++
.../reactor/groovy/config/ReactorBuilder.groovy | 361 +++++
.../groovy/config/ReactorScriptWrapper.groovy | 21 +
.../reactor/groovy/config/StreamEventRouter.java | 90 ++
.../org.codehaus.groovy.runtime.ExtensionModule | 21 +
.../groovy/reactor/groovy/CompileStaticTest.groovy | 55 +
.../reactor/groovy/GroovyConfigurationSpec.groovy | 132 ++
.../reactor/groovy/GroovyPromisesSpec.groovy | 173 +++
.../groovy/reactor/groovy/GroovyReactorSpec.groovy | 164 +++
.../groovy/reactor/groovy/GroovyStreamSpec.groovy | 261 ++++
.../reactor/groovy/StaticConfiguration.groovy | 146 ++
reactor-logback/README.md | 52 +
.../main/java/reactor/logback/AsyncAppender.java | 229 +++
.../java/reactor/logback/DurableAsyncAppender.java | 72 +
.../java/reactor/logback/DurableLogUtility.java | 175 +++
.../java/reactor/logback/LoggingEventRecord.java | 166 +++
.../src/test/java/reactor/dummy/Test.java | 25 +
.../java/reactor/logback/AsyncAppenderTests.java | 138 ++
reactor-logback/src/test/resources/logback.xml | 72 +
.../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 ++
.../net/tcp/encoding/SyslogCodecSpec.groovy | 26 +
.../tcp/netty/ClientServerIntegrationSpec.groovy | 162 +++
.../net/tcp/netty/NettyTcpServerSpec.groovy | 167 +++
.../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-net/src/test/resources/client.cer | Bin 0 -> 907 bytes
reactor-net/src/test/resources/client.jks | Bin 0 -> 2262 bytes
reactor-net/src/test/resources/server.cer | Bin 0 -> 907 bytes
reactor-net/src/test/resources/server.jks | Bin 0 -> 2263 bytes
settings.gradle | 7 +
src/api/overview.html | 17 +
src/api/stylesheet.css | 640 ++++++++
415 files changed, 50552 insertions(+)
--
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