Skip to content

Commit 0bf1ec0

Browse files
Stephan202akarnokd
authored andcommitted
Correct marble diagram dimensions (#5087)
2.x: Correct marble diagram dimensions
1 parent 8819cc9 commit 0bf1ec0

16 files changed

+64
-64
lines changed

src/main/java/io/reactivex/Completable.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1898,7 +1898,7 @@ public final <T> Flowable<T> toFlowable() {
18981898
/**
18991899
* Converts this Completable into a {@link Maybe}.
19001900
* <p>
1901-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.toObservable.png" alt="">
1901+
* <img width="640" height="293" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.toObservable.png" alt="">
19021902
* <dl>
19031903
* <dt><b>Scheduler:</b></dt>
19041904
* <dd>{@code toMaybe} does not operate by default on a particular {@link Scheduler}.</dd>

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

+16-16
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848
* <p>
4949
* The documentation for this class makes use of marble diagrams. The following legend explains these diagrams:
5050
* <p>
51-
* <img width="640" height="301" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/legend.png" alt="">
51+
* <img width="640" height="317" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/legend.png" alt="">
5252
* <p>
5353
* For more information see the <a href="http://reactivex.io/documentation/Publisher.html">ReactiveX
5454
* documentation</a>.
@@ -1825,7 +1825,7 @@ public static <T> Flowable<T> fromArray(T... items) {
18251825
* Returns a Flowable that, when a Subscriber subscribes to it, invokes a function you specify and then
18261826
* emits the value returned from that function.
18271827
* <p>
1828-
* <img width="640" height="195" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/fromCallable.png" alt="">
1828+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/fromCallable.png" alt="">
18291829
* <p>
18301830
* This allows you to defer the execution of the function you specify until a Subscriber subscribes to the
18311831
* Publisher. That is to say, it makes the function "lazy."
@@ -8189,7 +8189,7 @@ public final Single<T> first(T defaultItem) {
81898189
* Returns a Single that emits only the very first item emitted by this Flowable or
81908190
* signals a {@link NoSuchElementException} if this Flowable is empty.
81918191
* <p>
8192-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/firstOrError.png" alt="">
8192+
* <img width="640" height="237" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/firstOrError.png" alt="">
81938193
* <dl>
81948194
* <dt><b>Backpressure:</b></dt>
81958195
* <dd>The operator honors backpressure from downstream and consumes the source {@code Publisher} in an
@@ -9534,7 +9534,7 @@ public final Single<T> last(T defaultItem) {
95349534
* Returns a Single that emits only the last item emitted by this Flowable or signals
95359535
* a {@link NoSuchElementException} if this Flowable is empty.
95369536
* <p>
9537-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/lastOrError.png" alt="">
9537+
* <img width="640" height="236" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/lastOrError.png" alt="">
95389538
* <dl>
95399539
* <dt><b>Backpressure:</b></dt>
95409540
* <dd>The operator honors backpressure from downstream and consumes the source {@code Publisher} in an
@@ -10386,7 +10386,7 @@ public final Flowable<T> onTerminateDetach() {
1038610386
* <p>
1038710387
* To merge the parallel 'rails' back into a single sequence, use {@link ParallelFlowable#sequential()}.
1038810388
* <p>
10389-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flowable.parallel.png" alt="">
10389+
* <img width="640" height="547" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flowable.parallel.png" alt="">
1039010390
* <dl>
1039110391
* <dt><b>Backpressure:</b></dt>
1039210392
* <dd>The operator requires the upstream to honor backpressure and each 'rail' honors backpressure
@@ -10415,7 +10415,7 @@ public final ParallelFlowable<T> parallel() {
1041510415
* <p>
1041610416
* To merge the parallel 'rails' back into a single sequence, use {@link ParallelFlowable#sequential()}.
1041710417
* <p>
10418-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flowable.parallel.png" alt="">
10418+
* <img width="640" height="547" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flowable.parallel.png" alt="">
1041910419
* <dl>
1042010420
* <dt><b>Backpressure:</b></dt>
1042110421
* <dd>The operator requires the upstream to honor backpressure and each 'rail' honors backpressure
@@ -10447,7 +10447,7 @@ public final ParallelFlowable<T> parallel(int parallelism) {
1044710447
* <p>
1044810448
* To merge the parallel 'rails' back into a single sequence, use {@link ParallelFlowable#sequential()}.
1044910449
* <p>
10450-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flowable.parallel.png" alt="">
10450+
* <img width="640" height="547" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flowable.parallel.png" alt="">
1045110451
* <dl>
1045210452
* <dt><b>Backpressure:</b></dt>
1045310453
* <dd>The operator requires the upstream to honor backpressure and each 'rail' honors backpressure
@@ -11014,7 +11014,7 @@ public final <R> Flowable<R> replay(Function<? super Flowable<T>, ? extends Publ
1101411014
* emitted by a {@link ConnectableFlowable} that shares a single subscription to the source Publisher,
1101511015
* replaying no more than {@code bufferSize} items that were emitted within a specified time window.
1101611016
* <p>
11017-
* <img width="640" height="445" height="440" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/replay.fnts.png" alt="">
11017+
* <img width="640" height="445" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/replay.fnts.png" alt="">
1101811018
* <dl>
1101911019
* <dt><b>Backpressure:</b></dt>
1102011020
* <dd>This operator supports backpressure. Note that the upstream requests are determined by the child
@@ -11718,7 +11718,7 @@ public final Flowable<T> sample(long period, TimeUnit unit) {
1171811718
* Returns a Flowable that emits the most recently emitted item (if any) emitted by the source Publisher
1171911719
* within periodic time intervals and optionally emit the very last upstream item when the upstream completes.
1172011720
* <p>
11721-
* <img width="408" height="177" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.emitlast.png" alt="">
11721+
* <img width="640" height="276" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.emitlast.png" alt="">
1172211722
* <dl>
1172311723
* <dt><b>Backpressure:</b></dt>
1172411724
* <dd>This operator does not support backpressure as it uses time to control data flow.</dd>
@@ -11787,7 +11787,7 @@ public final Flowable<T> sample(long period, TimeUnit unit, Scheduler scheduler)
1178711787
* within periodic time intervals, where the intervals are defined on a particular Scheduler
1178811788
* and optionally emit the very last upstream item when the upstream completes.
1178911789
* <p>
11790-
* <img width="408" height="177" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.s.emitlast.png" alt="">
11790+
* <img width="640" height="276" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.s.emitlast.png" alt="">
1179111791
* <dl>
1179211792
* <dt><b>Backpressure:</b></dt>
1179311793
* <dd>This operator does not support backpressure as it uses time to control data flow.</dd>
@@ -11827,7 +11827,7 @@ public final Flowable<T> sample(long period, TimeUnit unit, Scheduler scheduler,
1182711827
* emits the most recently emitted item (if any) emitted by the source Publisher since the previous
1182811828
* emission from the {@code sampler} Publisher.
1182911829
* <p>
11830-
* <img width="437" height="198" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.o.nolast.png" alt="">
11830+
* <img width="640" height="289" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.o.nolast.png" alt="">
1183111831
* <dl>
1183211832
* <dt><b>Backpressure:</b></dt>
1183311833
* <dd>This operator does not support backpressure as it uses the emissions of the {@code sampler}
@@ -11858,7 +11858,7 @@ public final <U> Flowable<T> sample(Publisher<U> sampler) {
1185811858
* emission from the {@code sampler} Publisher
1185911859
* and optionally emit the very last upstream item when the upstream or other Publisher complete.
1186011860
* <p>
11861-
* <img width="437" height="198" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.o.emitlast.png" alt="">
11861+
* <img width="640" height="289" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/sample.o.emitlast.png" alt="">
1186211862
* <dl>
1186311863
* <dt><b>Backpressure:</b></dt>
1186411864
* <dd>This operator does not support backpressure as it uses the emissions of the {@code sampler}
@@ -12146,7 +12146,7 @@ public final Single<T> single(T defaultItem) {
1214612146
* if this Flowable completes without emitting any items a {@link NoSuchElementException} will be signalled and
1214712147
* if this Flowable emits more than one item, an {@code IllegalArgumentException} will be signalled.
1214812148
* <p>
12149-
* <img width="640" height="315" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/singleOrError.png" alt="">
12149+
* <img width="640" height="205" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/singleOrError.png" alt="">
1215012150
* <dl>
1215112151
* <dt><b>Backpressure:</b></dt>
1215212152
* <dd>The operator honors backpressure from downstream and consumes the source {@code Publisher} in an
@@ -12988,7 +12988,7 @@ public final Flowable<T> subscribeOn(Scheduler scheduler) {
1298812988
/**
1298912989
* Returns a Flowable that emits the items emitted by the source Publisher or the items of an alternate
1299012990
* Publisher if the source Publisher is empty.
12991-
* <img width="410" height="164" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/switchifempty.png" alt="">
12991+
* <img width="640" height="255" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/switchifempty.png" alt="">
1299212992
* <p/>
1299312993
* <dl>
1299412994
* <dt><b>Backpressure:</b></dt>
@@ -15589,7 +15589,7 @@ public final <U, V> Flowable<Flowable<T>> window(
1558915589
* Publisher emits connected, non-overlapping windows. It emits the current window and opens a new one
1559015590
* whenever the Publisher produced by the specified {@code closingSelector} emits an item.
1559115591
* <p>
15592-
* <img width="640" height="460" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/window1.png" alt="">
15592+
* <img width="640" height="455" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/window1.png" alt="">
1559315593
* <dl>
1559415594
* <dt><b>Backpressure:</b></dt>
1559515595
* <dd>The operator consumes the source {@code Publisher} in an unbounded manner.
@@ -15622,7 +15622,7 @@ public final <B> Flowable<Flowable<T>> window(Callable<? extends Publisher<B>> b
1562215622
* Publisher emits connected, non-overlapping windows. It emits the current window and opens a new one
1562315623
* whenever the Publisher produced by the specified {@code closingSelector} emits an item.
1562415624
* <p>
15625-
* <img width="640" height="460" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/window1.png" alt="">
15625+
* <img width="640" height="455" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/window1.png" alt="">
1562615626
* <dl>
1562715627
* <dt><b>Backpressure:</b></dt>
1562815628
* <dd>The operator consumes the source {@code Publisher} in an unbounded manner.

0 commit comments

Comments
 (0)