@@ -143,7 +143,7 @@ public static Completable concat(Iterable<? extends CompletableSource> sources)
143
143
/**
144
144
* Returns a Completable which completes only when all sources complete, one after another.
145
145
* <dl>
146
- * <dt><b>Backpressure:</b><dt>
146
+ * <dt><b>Backpressure:</b></ dt>
147
147
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
148
148
* and expects the other {@code Publisher} to honor it as well.</dd>
149
149
* <dt><b>Scheduler:</b></dt>
@@ -163,7 +163,7 @@ public static Completable concat(Publisher<? extends CompletableSource> sources)
163
163
/**
164
164
* Returns a Completable which completes only when all sources complete, one after another.
165
165
* <dl>
166
- * <dt><b>Backpressure:</b><dt>
166
+ * <dt><b>Backpressure:</b></ dt>
167
167
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
168
168
* and expects the other {@code Publisher} to honor it as well.</dd>
169
169
* <dt><b>Scheduler:</b></dt>
@@ -396,7 +396,7 @@ public static <T> Completable fromObservable(final ObservableSource<T> observabl
396
396
* Returns a Completable instance that subscribes to the given publisher, ignores all values and
397
397
* emits only the terminal event.
398
398
* <dl>
399
- * <dt><b>Backpressure:</b><dt>
399
+ * <dt><b>Backpressure:</b></ dt>
400
400
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
401
401
* and expects the other {@code Publisher} to honor it as well.</dd>
402
402
* <dt><b>Scheduler:</b></dt>
@@ -480,7 +480,7 @@ public static Completable merge(Iterable<? extends CompletableSource> sources) {
480
480
* Returns a Completable instance that subscribes to all sources at once and
481
481
* completes only when all source Completables complete or one of them emits an error.
482
482
* <dl>
483
- * <dt><b>Backpressure:</b><dt>
483
+ * <dt><b>Backpressure:</b></ dt>
484
484
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
485
485
* and expects the other {@code Publisher} to honor it as well.</dd>
486
486
* <dt><b>Scheduler:</b></dt>
@@ -501,7 +501,7 @@ public static Completable merge(Publisher<? extends CompletableSource> sources)
501
501
* Returns a Completable instance that keeps subscriptions to a limited number of sources at once and
502
502
* completes only when all source Completables complete or one of them emits an error.
503
503
* <dl>
504
- * <dt><b>Backpressure:</b><dt>
504
+ * <dt><b>Backpressure:</b></ dt>
505
505
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
506
506
* and expects the other {@code Publisher} to honor it as well.</dd>
507
507
* <dt><b>Scheduler:</b></dt>
@@ -525,7 +525,7 @@ public static Completable merge(Publisher<? extends CompletableSource> sources,
525
525
* completes only when all source Completables terminate in one way or another, combining any exceptions
526
526
* thrown by either the sources Observable or the inner Completable instances.
527
527
* <dl>
528
- * <dt><b>Backpressure:</b><dt>
528
+ * <dt><b>Backpressure:</b></ dt>
529
529
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer
530
530
* and expects the other {@code Publisher} to honor it as well.
531
531
* <dt><b>Scheduler:</b></dt>
@@ -591,7 +591,7 @@ public static Completable mergeDelayError(Iterable<? extends CompletableSource>
591
591
* any error emitted by either the sources observable or any of the inner Completables until all of
592
592
* them terminate in a way or another.
593
593
* <dl>
594
- * <dt><b>Backpressure:</b><dt>
594
+ * <dt><b>Backpressure:</b></ dt>
595
595
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
596
596
* and expects the other {@code Publisher} to honor it as well.</dd>
597
597
* <dt><b>Scheduler:</b></dt>
@@ -614,7 +614,7 @@ public static Completable mergeDelayError(Publisher<? extends CompletableSource>
614
614
* observable or any of the inner Completables until all of
615
615
* them terminate in a way or another.
616
616
* <dl>
617
- * <dt><b>Backpressure:</b><dt>
617
+ * <dt><b>Backpressure:</b></ dt>
618
618
* <dd>The returned {@code Completable} honors the backpressure of the downstream consumer
619
619
* and expects the other {@code Publisher} to honor it as well.</dd>
620
620
* <dt><b>Scheduler:</b></dt>
@@ -817,7 +817,7 @@ public final <T> Observable<T> andThen(ObservableSource<T> next) {
817
817
* propagated to the downstream subscriber and will result in skipping the subscription of the
818
818
* Publisher.
819
819
* <dl>
820
- * <dt><b>Backpressure:</b><dt>
820
+ * <dt><b>Backpressure:</b></ dt>
821
821
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer
822
822
* and expects the other {@code Publisher} to honor it as well.</dd>
823
823
* <dt><b>Scheduler:</b></dt>
@@ -1571,7 +1571,7 @@ public final <T> Observable<T> startWith(Observable<T> other) {
1571
1571
* Returns a Flowable which first delivers the events
1572
1572
* of the other Publisher then runs this Completable.
1573
1573
* <dl>
1574
- * <dt><b>Backpressure:</b><dt>
1574
+ * <dt><b>Backpressure:</b></ dt>
1575
1575
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer
1576
1576
* and expects the other {@code Publisher} to honor it as well.</dd>
1577
1577
* <dt><b>Scheduler:</b></dt>
@@ -1877,7 +1877,7 @@ public final <U> U to(Function<? super Completable, U> converter) {
1877
1877
* Returns a Flowable which when subscribed to subscribes to this Completable and
1878
1878
* relays the terminal events to the subscriber.
1879
1879
* <dl>
1880
- * <dt><b>Backpressure:</b><dt>
1880
+ * <dt><b>Backpressure:</b></ dt>
1881
1881
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
1882
1882
* <dt><b>Scheduler:</b></dt>
1883
1883
* <dd>{@code toFlowable} does not operate by default on a particular {@link Scheduler}.</dd>
0 commit comments