Prepare 3.0.6.RELEASE

reactor · Apr 4, 2017 · 82e0d67 · 82e0d67
1 parent 7e87857
commit 82e0d67
Show file tree

Hide file tree

Showing 16 changed files with 564 additions and 564 deletions.
diff --git a/README.md b/README.md
@@ -21,7 +21,7 @@ With Gradle from repo.spring.io or Maven Central repositories (stable releases o
 
     dependencies {
       //compile "io.projectreactor:reactor-core:3.0.6.BUILD-SNAPSHOT"
-      compile "io.projectreactor:reactor-core:3.0.5.RELEASE"
+      compile "io.projectreactor:reactor-core:3.0.6.RELEASE"
     }
 ```
 
@@ -38,7 +38,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.0.5.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.0.6.RELEASE/src/docs/marble/flux.png" width="500">](http://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html)
 
 Flux in action :
 ```java
@@ -57,7 +57,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.0.5.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.0.6.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/src/docs/asciidoc/advancedFeatures.adoc b/src/docs/asciidoc/advancedFeatures.adoc
@@ -24,7 +24,7 @@ Flux.fromIterable(Arrays.asList("blue", "green", "orange", "purple"))
 	.transform(filterAndMap)
 	.subscribe(d -> System.out.println("Subscriber to Transformed MapAndFilter: "+d));
 ----
-image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.5.RELEASE/src/docs/marble/gs-transform.png[Transform Operator : encapsulate flows]
+image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/gs-transform.png[Transform Operator : encapsulate flows]
 
 This outputs:
 
@@ -65,7 +65,7 @@ Flux.fromIterable(Arrays.asList("blue", "green", "orange", "purple"))
 composedFlux.subscribe(d -> System.out.println("Subscriber 1 to Composed MapAndFilter :"+d));
 composedFlux.subscribe(d -> System.out.println("Subscriber 2 to Composed MapAndFilter: "+d));
 ----
-image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.5.RELEASE/src/docs/marble/gs-compose.png[Compose Operator : Per Subscriber transformation]
+image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/gs-compose.png[Compose Operator : Per Subscriber transformation]
 
 This outputs:
 

diff --git a/src/docs/asciidoc/coreFeatures.adoc b/src/docs/asciidoc/coreFeatures.adoc
@@ -22,7 +22,7 @@ in `Flux`, but returns a `Mono<Long>`.
 [[flux]]
 == `Flux`, an asynchronous sequence of 0-n items
 
-image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.5.RELEASE/src/docs/marble/flux.png[Flux]
+image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/flux.png[Flux]
 
 
 A `Flux<T>` is a standard `Publisher<T>` representing an asynchronous sequence
@@ -41,7 +41,7 @@ sequences are not necessarily empty: `Flux.interval(Duration)` produces a
 
 [[mono]]
 == `Mono`, an asynchronous 0-1 result
-image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.5.RELEASE/src/docs/marble/mono.png[Mono]
+image::https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/mono.png[Mono]
 
 A `Mono<T>` is a specialized `Publisher<T>` that emits at most one item then
 optionally terminates with an `onComplete` signal or an `onError`.

diff --git a/src/docs/asciidoc/index.asciidoc b/src/docs/asciidoc/index.asciidoc
@@ -1,6 +1,6 @@
 = Reactor 3 Reference Guide
 Stephane Maldini <https://twitter.com/smaldini[@smaldini]>; Simon Baslé <https://twitter.com/simonbasle[@simonbasle]>
-:appversion: 3.0.5.RELEASE
+:appversion: 3.0.6.RELEASE
 ifndef::host-github[:ext-relative: {outfilesuffix}]
 {appversion}
 :doctype: book

diff --git a/src/main/java/reactor/core/publisher/ConnectableFlux.java b/src/main/java/reactor/core/publisher/ConnectableFlux.java
@@ -36,7 +36,7 @@ public abstract class ConnectableFlux<T> extends Flux<T> implements Receiver {
 	 * subscribes.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.5.RELEASE/src/docs/marble/autoconnect.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.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
 	 */
@@ -52,7 +52,7 @@ public final Flux<T> autoConnect() {
 	 * that triggers the connection.
 	 *
 	 * <p>
-	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.5.RELEASE/src/docs/marble/autoconnect.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/autoconnect.png" alt="">
 	 *
 	 * @param minSubscribers the minimum number of subscribers
 	 *
@@ -69,7 +69,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.0.5.RELEASE/src/docs/marble/autoconnect.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/autoconnect.png" alt="">
 	 *
 	 * @return a {@link Flux} that connects to the upstream source when the given amount of subscribers subscribed
 	 */
@@ -116,7 +116,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.0.5.RELEASE/src/docs/marble/refCount.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/refCount.png" alt="">
 	 *
 	 * @return a reference counting {@link Flux}
 	 */
@@ -129,7 +129,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.0.5.RELEASE/src/docs/marble/refCount.png" alt="">
+	 * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.0.6.RELEASE/src/docs/marble/refCount.png" alt="">
 	 *
 	 * @param minSubscribers the number of subscribers expected to subscribe before connection
 	 *

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