diff --git a/context-propagation/pom.xml b/context-propagation/pom.xml index eb24eadf9..a7688ff5a 100644 --- a/context-propagation/pom.xml +++ b/context-propagation/pom.xml @@ -7,7 +7,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny-context-propagation diff --git a/documentation/pom.xml b/documentation/pom.xml index 31e523225..8114fec04 100644 --- a/documentation/pom.xml +++ b/documentation/pom.xml @@ -5,7 +5,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny-documentation diff --git a/implementation/pom.xml b/implementation/pom.xml index ca785181c..27a647fc2 100644 --- a/implementation/pom.xml +++ b/implementation/pom.xml @@ -6,7 +6,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny diff --git a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/processors/UnicastProcessor.java b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/processors/UnicastProcessor.java index 21cabceb0..716dc26db 100644 --- a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/processors/UnicastProcessor.java +++ b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/processors/UnicastProcessor.java @@ -1,20 +1,21 @@ package io.smallrye.mutiny.operators.multi.processors; +import java.util.Queue; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; +import java.util.concurrent.atomic.AtomicReference; + +import org.reactivestreams.Processor; +import org.reactivestreams.Subscriber; +import org.reactivestreams.Subscription; + import io.smallrye.mutiny.helpers.ParameterValidation; import io.smallrye.mutiny.helpers.Subscriptions; import io.smallrye.mutiny.helpers.queues.SpscLinkedArrayQueue; import io.smallrye.mutiny.operators.AbstractMulti; import io.smallrye.mutiny.subscription.BackPressureFailure; import io.smallrye.mutiny.subscription.MultiSubscriber; -import org.reactivestreams.Processor; -import org.reactivestreams.Subscriber; -import org.reactivestreams.Subscription; - -import java.util.Queue; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.concurrent.atomic.AtomicInteger; -import java.util.concurrent.atomic.AtomicLong; -import java.util.concurrent.atomic.AtomicReference; /** * Implementation of a processor using a queue to store items and allows a single subscriber to receive @@ -50,9 +51,9 @@ public static UnicastProcessor create() { /** * Creates a new {@link UnicastProcessor} using the given queue. * - * @param queue the queue, must not be {@code null} + * @param queue the queue, must not be {@code null} * @param onTermination the termination callback, can be {@code null} - * @param the type of item + * @param the type of item * @return the unicast processor */ public static UnicastProcessor create(Queue queue, Runnable onTermination) { @@ -75,7 +76,7 @@ void drainWithDownstream(Subscriber actual) { final Queue q = queue; - for (; ; ) { + for (;;) { long r = requested.get(); long e = 0L; @@ -122,7 +123,7 @@ private void drain() { } int missed = 1; - for (; ; ) { + for (;;) { Subscriber actual = downstream.get(); if (actual != null) { drainWithDownstream(actual); diff --git a/pom.xml b/pom.xml index 0d9660888..c83a16bba 100644 --- a/pom.xml +++ b/pom.xml @@ -10,7 +10,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 pom SmallRye Mutiny Project diff --git a/reactive-streams-operators/pom.xml b/reactive-streams-operators/pom.xml index d60581861..91488a9ed 100644 --- a/reactive-streams-operators/pom.xml +++ b/reactive-streams-operators/pom.xml @@ -5,7 +5,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny-reactive-streams-operators diff --git a/reactor/pom.xml b/reactor/pom.xml index 9e8b30a33..37aba8a2e 100644 --- a/reactor/pom.xml +++ b/reactor/pom.xml @@ -5,7 +5,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny-reactor diff --git a/release/pom.xml b/release/pom.xml index 0c25243b5..d135929b5 100644 --- a/release/pom.xml +++ b/release/pom.xml @@ -5,7 +5,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 smallrye-mutiny-release diff --git a/rxjava/pom.xml b/rxjava/pom.xml index 05ce3992f..d066633fd 100644 --- a/rxjava/pom.xml +++ b/rxjava/pom.xml @@ -5,7 +5,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny-rxjava diff --git a/test-utils/pom.xml b/test-utils/pom.xml index 43addde9a..083691f78 100644 --- a/test-utils/pom.xml +++ b/test-utils/pom.xml @@ -5,7 +5,7 @@ io.smallrye.reactive mutiny-project - 999-SNAPSHOT + 0.3.1 mutiny-test-utils