Skip to content

Commit bb93911

Browse files
UMFsimkeakarnokd
authored andcommitted
2.x: Add marbles for Single.concat operator (#6137)
* Add marbles for Single.concat operator * Update URL for Single.concat marble diagram * Update Single.concat marble's height
1 parent 690258e commit bb93911

File tree

1 file changed

+13
-3
lines changed

1 file changed

+13
-3
lines changed

Diff for: src/main/java/io/reactivex/Single.java

+13-3
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,8 @@ public static <T> Single<T> ambArray(final SingleSource<? extends T>... sources)
166166
/**
167167
* Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by
168168
* an Iterable sequence.
169+
* <p>
170+
* <img width="640" height="319" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.i.png" alt="">
169171
* <dl>
170172
* <dt><b>Backpressure:</b></dt>
171173
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
@@ -187,6 +189,8 @@ public static <T> Flowable<T> concat(Iterable<? extends SingleSource<? extends T
187189
/**
188190
* Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by
189191
* an Observable sequence.
192+
* <p>
193+
* <img width="640" height="319" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.o.png" alt="">
190194
* <dl>
191195
* <dt><b>Scheduler:</b></dt>
192196
* <dd>{@code concat} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -207,6 +211,8 @@ public static <T> Observable<T> concat(ObservableSource<? extends SingleSource<?
207211
/**
208212
* Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by
209213
* a Publisher sequence.
214+
* <p>
215+
* <img width="640" height="308" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.p.png" alt="">
210216
* <dl>
211217
* <dt><b>Backpressure:</b></dt>
212218
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer
@@ -229,6 +235,8 @@ public static <T> Flowable<T> concat(Publisher<? extends SingleSource<? extends
229235
/**
230236
* Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by
231237
* a Publisher sequence and prefetched by the specified amount.
238+
* <p>
239+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.pn.png" alt="">
232240
* <dl>
233241
* <dt><b>Backpressure:</b></dt>
234242
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer
@@ -255,7 +263,7 @@ public static <T> Flowable<T> concat(Publisher<? extends SingleSource<? extends
255263
/**
256264
* Returns a Flowable that emits the items emitted by two Singles, one after the other.
257265
* <p>
258-
* <img width="640" height="380" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.png" alt="">
266+
* <img width="640" height="366" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.png" alt="">
259267
* <dl>
260268
* <dt><b>Backpressure:</b></dt>
261269
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
@@ -286,7 +294,7 @@ public static <T> Flowable<T> concat(
286294
/**
287295
* Returns a Flowable that emits the items emitted by three Singles, one after the other.
288296
* <p>
289-
* <img width="640" height="380" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.png" alt="">
297+
* <img width="640" height="366" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.o3.png" alt="">
290298
* <dl>
291299
* <dt><b>Backpressure:</b></dt>
292300
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
@@ -321,7 +329,7 @@ public static <T> Flowable<T> concat(
321329
/**
322330
* Returns a Flowable that emits the items emitted by four Singles, one after the other.
323331
* <p>
324-
* <img width="640" height="380" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.png" alt="">
332+
* <img width="640" height="362" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concat.o4.png" alt="">
325333
* <dl>
326334
* <dt><b>Backpressure:</b></dt>
327335
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
@@ -359,6 +367,8 @@ public static <T> Flowable<T> concat(
359367
/**
360368
* Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided in
361369
* an array.
370+
* <p>
371+
* <img width="640" height="319" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.concatArray.png" alt="">
362372
* <dl>
363373
* <dt><b>Backpressure:</b></dt>
364374
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>

0 commit comments

Comments
 (0)