Skip to content

Commit da06e59

Browse files
authored
2.x: fix images of firstElement, flattenAsX, flatMapIterable (ReactiveX#5208)
* 2.x: fix images of firstElement, flattenAsX, flatMapIterable * +UnicastSubject, +UnicastProcessor
1 parent ab0c590 commit da06e59

File tree

6 files changed

+18
-14
lines changed

6 files changed

+18
-14
lines changed

src/main/java/io/reactivex/Flowable.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8163,7 +8163,7 @@ public final Flowable<T> filter(Predicate<? super T> predicate) {
81638163
* Returns a Maybe that emits only the very first item emitted by this Flowable or
81648164
* completes if this Flowable is empty.
81658165
* <p>
8166-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/first.png" alt="">
8166+
* <img width="640" height="237" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/firstElement.m.png" alt="">
81678167
* <dl>
81688168
* <dt><b>Backpressure:</b></dt>
81698169
* <dd>The operator honors backpressure from downstream and consumes the source {@code Publisher} in an
@@ -8186,7 +8186,7 @@ public final Maybe<T> firstElement() {
81868186
* Returns a Single that emits only the very first item emitted by this Flowable, or a default
81878187
* item if this Flowable completes without emitting anything.
81888188
* <p>
8189-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/firstOrDefault.png" alt="">
8189+
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/first.s.png" alt="">
81908190
* <dl>
81918191
* <dt><b>Backpressure:</b></dt>
81928192
* <dd>The operator honors backpressure from downstream and consumes the source {@code Publisher} in an
@@ -8772,7 +8772,7 @@ public final Completable flatMapCompletable(Function<? super T, ? extends Comple
87728772
* Returns a Flowable that merges each item emitted by the source Publisher with the values in an
87738773
* Iterable corresponding to that item that is generated by a selector.
87748774
* <p>
8775-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMapIterable.png" alt="">
8775+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.f.png" alt="">
87768776
* <dl>
87778777
* <dt><b>Backpressure:</b></dt>
87788778
* <dd>The operator honors backpressure from downstream. The source {@code Publisher}s is
@@ -8802,7 +8802,7 @@ public final <U> Flowable<U> flatMapIterable(final Function<? super T, ? extends
88028802
* Returns a Flowable that merges each item emitted by the source Publisher with the values in an
88038803
* Iterable corresponding to that item that is generated by a selector.
88048804
* <p>
8805-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMapIterable.png" alt="">
8805+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.f.png" alt="">
88068806
* <dl>
88078807
* <dt><b>Backpressure:</b></dt>
88088808
* <dd>The operator honors backpressure from downstream. The source {@code Publisher}s is
@@ -8836,7 +8836,7 @@ public final <U> Flowable<U> flatMapIterable(final Function<? super T, ? extends
88368836
* Returns a Flowable that emits the results of applying a function to the pair of values from the source
88378837
* Publisher and an Iterable corresponding to that item that is generated by a selector.
88388838
* <p>
8839-
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMapIterable.r.png" alt="">
8839+
* <img width="640" height="410" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.f.r.png" alt="">
88408840
* <dl>
88418841
* <dt><b>Backpressure:</b></dt>
88428842
* <dd>The operator honors backpressure from downstream and the source {@code Publisher}s is
@@ -8874,7 +8874,7 @@ public final <U, V> Flowable<V> flatMapIterable(final Function<? super T, ? exte
88748874
* Iterable corresponding to that item that is generated by a selector, while limiting the number of concurrent
88758875
* subscriptions to these Publishers.
88768876
* <p>
8877-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMapIterable.png" alt="">
8877+
* <img width="640" height="410" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.f.r.png" alt="">
88788878
* <dl>
88798879
* <dt><b>Backpressure:</b></dt>
88808880
* <dd>The operator honors backpressure from downstream. The source {@code Publisher}s is

src/main/java/io/reactivex/Maybe.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2696,7 +2696,7 @@ public final <U, R> Maybe<R> flatMap(Function<? super T, ? extends MaybeSource<?
26962696
* Returns a Flowable that merges each item emitted by the source Maybe with the values in an
26972697
* Iterable corresponding to that item that is generated by a selector.
26982698
* <p>
2699-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">mergeMapIterable.png" alt="">
2699+
* <img width="640" height="373" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">flattenAsFlowable.png" alt="">
27002700
* <dl>
27012701
* <dt><b>Backpressure:</b></dt>
27022702
* <dd>The operator honors backpressure from downstream.</dd>
@@ -2723,7 +2723,7 @@ public final <U> Flowable<U> flattenAsFlowable(final Function<? super T, ? exten
27232723
/**
27242724
* Returns an Observable that maps a success value into an Iterable and emits its items.
27252725
* <p>
2726-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">mergeMapIterable.png" alt="">
2726+
* <img width="640" height="373" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">flattenAsObservable.png" alt="">
27272727
* <dl>
27282728
* <dt><b>Scheduler:</b></dt>
27292729
* <dd>{@code flattenAsObservable} does not operate by default on a particular {@link Scheduler}.</dd>

src/main/java/io/reactivex/Observable.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7242,7 +7242,7 @@ public final Observable<T> filter(Predicate<? super T> predicate) {
72427242
* Returns a Maybe that emits only the very first item emitted by the source ObservableSource, or
72437243
* completes if the source ObservableSource is empty.
72447244
* <p>
7245-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/firstElement.png" alt="">
7245+
* <img width="640" height="237" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/firstElement.m.png" alt="">
72467246
* <dl>
72477247
* <dt><b>Scheduler:</b></dt>
72487248
* <dd>{@code firstElement} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -7261,7 +7261,7 @@ public final Maybe<T> firstElement() {
72617261
* Returns a Single that emits only the very first item emitted by the source ObservableSource, or a default item
72627262
* if the source ObservableSource completes without emitting any items.
72637263
* <p>
7264-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/first.2.png" alt="">
7264+
* <img width="640" height="286" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/first.s.png" alt="">
72657265
* <dl>
72667266
* <dt><b>Scheduler:</b></dt>
72677267
* <dd>{@code first} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -7753,7 +7753,7 @@ public final Completable flatMapCompletable(Function<? super T, ? extends Comple
77537753
* Returns an Observable that merges each item emitted by the source ObservableSource with the values in an
77547754
* Iterable corresponding to that item that is generated by a selector.
77557755
* <p>
7756-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMapIterable.png" alt="">
7756+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.o.png" alt="">
77577757
* <dl>
77587758
* <dt><b>Scheduler:</b></dt>
77597759
* <dd>{@code flatMapIterable} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -7779,7 +7779,7 @@ public final <U> Observable<U> flatMapIterable(final Function<? super T, ? exten
77797779
* Returns an Observable that emits the results of applying a function to the pair of values from the source
77807780
* ObservableSource and an Iterable corresponding to that item that is generated by a selector.
77817781
* <p>
7782-
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMapIterable.r.png" alt="">
7782+
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.o.r.png" alt="">
77837783
* <dl>
77847784
* <dt><b>Scheduler:</b></dt>
77857785
* <dd>{@code flatMapIterable} does not operate by default on a particular {@link Scheduler}.</dd>

src/main/java/io/reactivex/Single.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2045,7 +2045,7 @@ public final <R> Flowable<R> flatMapPublisher(Function<? super T, ? extends Publ
20452045
* Returns a Flowable that merges each item emitted by the source Single with the values in an
20462046
* Iterable corresponding to that item that is generated by a selector.
20472047
* <p>
2048-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">mergeMapIterable.png" alt="">
2048+
* <img width="640" height="373" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">flattenAsFlowable.png" alt="">
20492049
* <dl>
20502050
* <dt><b>Backpressure:</b></dt>
20512051
* <dd>The operator honors backpressure from downstream.</dd>
@@ -2072,7 +2072,7 @@ public final <U> Flowable<U> flattenAsFlowable(final Function<? super T, ? exten
20722072
/**
20732073
* Returns an Observable that maps a success value into an Iterable and emits its items.
20742074
* <p>
2075-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">mergeMapIterable.png" alt="">
2075+
* <img width="640" height="373" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/%3Cspan%20class="x x-first x-last">flattenAsObservable.png" alt="">
20762076
* <dl>
20772077
* <dt><b>Scheduler:</b></dt>
20782078
* <dd>{@code flattenAsObservable} does not operate by default on a particular {@link Scheduler}.</dd>

src/main/java/io/reactivex/processors/UnicastProcessor.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@
3737
* will receive an IllegalStateException if this Processor hasn't terminated yet,
3838
* or the Subscribers receive the terminal event (error or completion) if this
3939
* Processor has terminated.
40+
* <p>
41+
* <img width="640" height="370" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/UnicastProcessor.png" alt="">
4042
*
4143
* @param <T> the value type received and emitted by this Processor subclass
4244
* @since 2.0

src/main/java/io/reactivex/subjects/UnicastSubject.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@
3737
* will receive an IllegalStateException if this Subject hasn't terminated yet,
3838
* or the Subscribers receive the terminal event (error or completion) if this
3939
* Subject has terminated.
40+
* <p>
41+
* <img width="640" height="370" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/UnicastSubject.png" alt="">
4042
*
4143
* @param <T> the value type received and emitted by this Subject subclass
4244
* @since 2.0

0 commit comments

Comments
 (0)