Skip to content

Commit

Permalink
update javadoc links
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephane Maldini committed Jul 18, 2017
1 parent 8e75104 commit b125047
Show file tree
Hide file tree
Showing 12 changed files with 485 additions and 485 deletions.
14 changes: 7 additions & 7 deletions reactor-core/src/main/java/reactor/core/publisher/ConnectableFlux.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.0.M2/src/docs/marble/autoconnect.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/autoconnect.png" alt="">
*
* @return a {@link Flux} that connects to the upstream source when the first {@link org.reactivestreams.Subscriber} subscribes
*/
Expand All @@ -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.0.M2/src/docs/marble/autoconnect.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/autoconnect.png" alt="">
*
* @param minSubscribers the minimum number of subscribers
*
Expand All @@ -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.0.M2/src/docs/marble/autoconnect.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/autoconnect.png" alt="">
*
* @return a {@link Flux} that connects to the upstream source when the given amount of subscribers subscribed
*/
Expand Down Expand Up @@ -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.0.M2/src/docs/marble/refCount.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/refCount.png" alt="">
*
* @return a reference counting {@link Flux}
*/
Expand All @@ -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.0.M2/src/docs/marble/refCount.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/refCount.png" alt="">
*
* @param minSubscribers the number of subscribers expected to subscribe before connection
*
Expand All @@ -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.0.M2/src/docs/marble/refCount.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/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
Expand All @@ -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.0.M2/src/docs/marble/refCount.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/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
Expand Down
2 changes: 1 addition & 1 deletion reactor-core/src/main/java/reactor/core/publisher/EmitterProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,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.0.M2/src/docs/marble/emitter.png"
* <img width="640" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/emitter.png"
* alt="">
* <p>
*
Expand Down
654 changes: 327 additions & 327 deletions reactor-core/src/main/java/reactor/core/publisher/Flux.java
View file

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion reactor-core/src/main/java/reactor/core/publisher/FluxProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public abstract class FluxProcessor<IN, OUT> extends Flux<OUT>
* completed.
*
* <p>
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M2/src/docs/marble/switchonnext.png" alt="">
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/switchonnext.png" alt="">
*
* @param <T> the produced type
* @return a {@link FluxProcessor} accepting publishers and producing T
Expand Down
8 changes: 4 additions & 4 deletions reactor-core/src/main/java/reactor/core/publisher/Hooks.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -405,7 +405,7 @@ public final OperatorHook<T> ifNameContains(String... names){
* Operators.signalLogger(source, "category", Level.INFO, SignalType.ON_NEXT,
* SignalType.ON_ERROR)
*
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M2/src/docs/marble/log.png"
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/log.png"
* alt="">
*
* @param category to be mapped into logger configuration (e.g.
Expand All @@ -432,7 +432,7 @@ public OperatorHook<T> log(@Nullable String category, SignalType... options){
* Operators.signalLogger(source, "category", Level.INFO, SignalType.ON_NEXT,
* SignalType.ON_ERROR)
*
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M2/src/docs/marble/log.png"
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/log.png"
* alt="">
*
* @param category to be mapped into logger configuration (e.g.
Expand Down Expand Up @@ -462,7 +462,7 @@ public OperatorHook<T> log(@Nullable String category, boolean showOperatorLine,
* Operators.signalLogger(source, "category", Level.INFO, SignalType.ON_NEXT,
* SignalType.ON_ERROR)
*
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M2/src/docs/marble/log.png"
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/log.png"
* alt="">
*
* @param category to be mapped into logger configuration (e.g.
Expand Down Expand Up @@ -495,7 +495,7 @@ public OperatorHook<T> log(@Nullable String category, Level level, SignalType...
* Operators.signalLogger(source, "category", Level.INFO, SignalType.ON_NEXT,
* SignalType.ON_ERROR)
*
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M2/src/docs/marble/log.png"
* <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.M3/src/docs/marble/log.png"
* alt="">
*
* @param category to be mapped into logger configuration (e.g.
Expand Down
Loading

0 comments on commit b125047

Please sign in to comment.