Skip to content

Commit

Permalink
[RELEASE] - Bump version to 0.3.1
Browse files Browse the repository at this point in the history
  • Loading branch information
smallrye-ci committed Jan 14, 2020
1 parent 9748d93 commit 375d458
Show file tree
Hide file tree
Showing 10 changed files with 23 additions and 22 deletions.
2 changes: 1 addition & 1 deletion context-propagation/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny-context-propagation</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion documentation/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny-documentation</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion implementation/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny</artifactId>
Expand Down
Original file line number Diff line number Diff line change
@@ -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
Expand Down Expand Up @@ -50,9 +51,9 @@ public static <I> UnicastProcessor<I> 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 <I> the type of item
* @param <I> the type of item
* @return the unicast processor
*/
public static <I> UnicastProcessor<I> create(Queue<I> queue, Runnable onTermination) {
Expand All @@ -75,7 +76,7 @@ void drainWithDownstream(Subscriber<? super T> actual) {

final Queue<T> q = queue;

for (; ; ) {
for (;;) {

long r = requested.get();
long e = 0L;
Expand Down Expand Up @@ -122,7 +123,7 @@ private void drain() {
}

int missed = 1;
for (; ; ) {
for (;;) {
Subscriber<? super T> actual = downstream.get();
if (actual != null) {
drainWithDownstream(actual);
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@

<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
<packaging>pom</packaging>

<name>SmallRye Mutiny Project</name>
Expand Down
2 changes: 1 addition & 1 deletion reactive-streams-operators/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny-reactive-streams-operators</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion reactor/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny-reactor</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion release/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>smallrye-mutiny-release</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion rxjava/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny-rxjava</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion test-utils/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>io.smallrye.reactive</groupId>
<artifactId>mutiny-project</artifactId>
<version>999-SNAPSHOT</version>
<version>0.3.1</version>
</parent>

<artifactId>mutiny-test-utils</artifactId>
Expand Down

0 comments on commit 375d458

Please sign in to comment.