Prepare 3.1.3

reactor · Jan 18, 2018 · 0a89587 · 0a89587
1 parent 0a3f5fb
commit 0a89587
Show file tree

Hide file tree

Showing 13 changed files with 494 additions and 494 deletions.
diff --git a/README.md b/README.md
@@ -25,10 +25,10 @@ With Gradle from repo.spring.io or Maven Central repositories (stable releases o
     }
 
     dependencies {
-      //compile "io.projectreactor:reactor-core:3.1.3.BUILD-SNAPSHOT"
-      //testCompile("io.projectreactor:reactor-test:3.1.3.BUILD-SNAPSHOT")
-      compile "io.projectreactor:reactor-core:3.1.2.RELEASE"
-      testCompile("io.projectreactor:reactor-test:3.1.2.RELEASE")
+      //compile "io.projectreactor:reactor-core:3.1.4.BUILD-SNAPSHOT"
+      //testCompile("io.projectreactor:reactor-test:3.1.4.BUILD-SNAPSHOT")
+      compile "io.projectreactor:reactor-core:3.1.3.RELEASE"
+      testCompile("io.projectreactor:reactor-test:3.1.3.RELEASE")
     }
 ```
 
@@ -54,7 +54,7 @@ A Reactive Streams Publisher with basic flow operators.
 - Static factories on Flux allow for source generation from arbitrary callbacks types.
 - Instance methods allows operational building, materialized on each _Flux#subscribe()_, _Flux#subscribe()_ or multicasting operations such as _Flux#publish_ and _Flux#publishNext_.
 
-[<img src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/flux.png" width="500">](http://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html)
+[<img src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/flux.png" width="500">](http://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html)
 
 Flux in action :
 ```java
@@ -73,7 +73,7 @@ A Reactive Streams Publisher constrained to *ZERO* or *ONE* element with appropr
 - Static factories on Mono allow for deterministic *zero or one* sequence generation from arbitrary callbacks types.
 - Instance methods allows operational building, materialized on each _Mono#subscribe()_ or _Mono#get()_ eventually called.
 
-[<img src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/mono.png" width="500">](http://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html)
+[<img src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/mono.png" width="500">](http://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html)
 
 Mono in action :
 ```java

diff --git a/reactor-core/src/main/java/reactor/core/publisher/ConnectableFlux.java b/reactor-core/src/main/java/reactor/core/publisher/ConnectableFlux.java
@@ -38,7 +38,7 @@ public abstract class ConnectableFlux<T> extends Flux<T> {
 	 * subscribes.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/autoconnect.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/autoconnect.png" alt="">
 	 *
 	 * @return a {@link Flux} that connects to the upstream source when the first {@link org.reactivestreams.Subscriber} subscribes
 	 */
@@ -54,7 +54,7 @@ public final Flux<T> autoConnect() {
 	 * triggers the connection.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/autoconnect.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/autoconnect.png" alt="">
 	 *
 	 * @param minSubscribers the minimum number of subscribers
 	 *
@@ -71,7 +71,7 @@ public final Flux<T> autoConnect(int minSubscribers) {
 	 * @param cancelSupport the consumer that will receive the {@link Disposable} that allows disconnecting
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/autoconnect.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/autoconnect.png" alt="">
 	 *
 	 * @return a {@link Flux} that connects to the upstream source when the given amount of subscribers subscribed
 	 */
@@ -118,7 +118,7 @@ public final Disposable connect() {
 	 * when all Subscribers cancelled or the upstream source completed.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/refCount.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/refCount.png" alt="">
 	 *
 	 * @return a reference counting {@link Flux}
 	 */
@@ -131,7 +131,7 @@ public final Flux<T> refCount() {
 	 * when all Subscribers cancelled or the upstream source completed.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/refCount.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/refCount.png" alt="">
 	 *
 	 * @param minSubscribers the number of subscribers expected to subscribe before connection
 	 *
@@ -149,7 +149,7 @@ public final Flux<T> refCount(int minSubscribers) {
 	 * in during the {@code gracePeriod} that follows, the disconnection is cancelled.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/refCount.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/refCount.png" alt="">
 	 *
 	 * @param minSubscribers the number of subscribers expected to subscribe before connection
 	 * @param gracePeriod the {@link Duration} for which to wait for new subscribers before actually
@@ -169,7 +169,7 @@ public final Flux<T> refCount(int minSubscribers, Duration gracePeriod) {
 	 * in during the {@code gracePeriod} that follows, the disconnection is cancelled.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/refCount.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/refCount.png" alt="">
 	 *
 	 * @param minSubscribers the number of subscribers expected to subscribe before connection
 	 * @param gracePeriod the {@link Duration} for which to wait for new subscribers before actually

diff --git a/reactor-core/src/main/java/reactor/core/publisher/EmitterProcessor.java b/reactor-core/src/main/java/reactor/core/publisher/EmitterProcessor.java
@@ -44,7 +44,7 @@
  * the parent sequence after a given {@link Subscriber} is subscribed.
  * <p>
  * <p>
- * <img width="640" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.1.RELEASE/src/docs/marble/emitter.png"
+ * <img width="640" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.3.RELEASE/src/docs/marble/emitter.png"
  * alt="">
  * <p>
  *