diff --git a/src/main/java/io/reactivex/Flowable.java b/src/main/java/io/reactivex/Flowable.java index 2f30236606..8570a5782b 100644 --- a/src/main/java/io/reactivex/Flowable.java +++ b/src/main/java/io/reactivex/Flowable.java @@ -8163,7 +8163,7 @@ public final Flowable filter(Predicate predicate) { * Returns a Maybe that emits only the very first item emitted by this Flowable or * completes if this Flowable is empty. *

- * + * *

*
Backpressure:
*
The operator honors backpressure from downstream and consumes the source {@code Publisher} in an @@ -8186,7 +8186,7 @@ public final Maybe firstElement() { * Returns a Single that emits only the very first item emitted by this Flowable, or a default * item if this Flowable completes without emitting anything. *

- * + * *

*
Backpressure:
*
The operator honors backpressure from downstream and consumes the source {@code Publisher} in an @@ -8772,7 +8772,7 @@ public final Completable flatMapCompletable(Function - * + * *
*
Backpressure:
*
The operator honors backpressure from downstream. The source {@code Publisher}s is @@ -8802,7 +8802,7 @@ public final Flowable flatMapIterable(final Function - * + * *
*
Backpressure:
*
The operator honors backpressure from downstream. The source {@code Publisher}s is @@ -8836,7 +8836,7 @@ public final Flowable flatMapIterable(final Function - * + * *
*
Backpressure:
*
The operator honors backpressure from downstream and the source {@code Publisher}s is @@ -8874,7 +8874,7 @@ public final Flowable flatMapIterable(final Function - * + * *
*
Backpressure:
*
The operator honors backpressure from downstream. The source {@code Publisher}s is diff --git a/src/main/java/io/reactivex/Maybe.java b/src/main/java/io/reactivex/Maybe.java index 779fb79ae9..c2b8826ec2 100644 --- a/src/main/java/io/reactivex/Maybe.java +++ b/src/main/java/io/reactivex/Maybe.java @@ -2696,7 +2696,7 @@ public final Maybe flatMap(Function - * + * *
*
Backpressure:
*
The operator honors backpressure from downstream.
@@ -2723,7 +2723,7 @@ public final Flowable flattenAsFlowable(final Function - * + * *
*
Scheduler:
*
{@code flattenAsObservable} does not operate by default on a particular {@link Scheduler}.
diff --git a/src/main/java/io/reactivex/Observable.java b/src/main/java/io/reactivex/Observable.java index 2d1e36dd54..0b771ae4c2 100644 --- a/src/main/java/io/reactivex/Observable.java +++ b/src/main/java/io/reactivex/Observable.java @@ -7242,7 +7242,7 @@ public final Observable filter(Predicate predicate) { * Returns a Maybe that emits only the very first item emitted by the source ObservableSource, or * completes if the source ObservableSource is empty. *

- * + * *

*
Scheduler:
*
{@code firstElement} does not operate by default on a particular {@link Scheduler}.
@@ -7261,7 +7261,7 @@ public final Maybe firstElement() { * Returns a Single that emits only the very first item emitted by the source ObservableSource, or a default item * if the source ObservableSource completes without emitting any items. *

- * + * *

*
Scheduler:
*
{@code first} does not operate by default on a particular {@link Scheduler}.
@@ -7753,7 +7753,7 @@ public final Completable flatMapCompletable(Function - * + * *
*
Scheduler:
*
{@code flatMapIterable} does not operate by default on a particular {@link Scheduler}.
@@ -7779,7 +7779,7 @@ public final Observable flatMapIterable(final Function - * + * *
*
Scheduler:
*
{@code flatMapIterable} does not operate by default on a particular {@link Scheduler}.
diff --git a/src/main/java/io/reactivex/Single.java b/src/main/java/io/reactivex/Single.java index d0e65336e2..51081bb44e 100644 --- a/src/main/java/io/reactivex/Single.java +++ b/src/main/java/io/reactivex/Single.java @@ -2045,7 +2045,7 @@ public final Flowable flatMapPublisher(Function - * + * *
*
Backpressure:
*
The operator honors backpressure from downstream.
@@ -2072,7 +2072,7 @@ public final Flowable flattenAsFlowable(final Function - * + * *
*
Scheduler:
*
{@code flattenAsObservable} does not operate by default on a particular {@link Scheduler}.
diff --git a/src/main/java/io/reactivex/processors/UnicastProcessor.java b/src/main/java/io/reactivex/processors/UnicastProcessor.java index ecd624da8c..88f2e9cbed 100644 --- a/src/main/java/io/reactivex/processors/UnicastProcessor.java +++ b/src/main/java/io/reactivex/processors/UnicastProcessor.java @@ -37,6 +37,8 @@ * will receive an IllegalStateException if this Processor hasn't terminated yet, * or the Subscribers receive the terminal event (error or completion) if this * Processor has terminated. + *

+ * * * @param the value type received and emitted by this Processor subclass * @since 2.0 diff --git a/src/main/java/io/reactivex/subjects/UnicastSubject.java b/src/main/java/io/reactivex/subjects/UnicastSubject.java index b5054d52ba..4a1b8815e9 100644 --- a/src/main/java/io/reactivex/subjects/UnicastSubject.java +++ b/src/main/java/io/reactivex/subjects/UnicastSubject.java @@ -37,6 +37,8 @@ * will receive an IllegalStateException if this Subject hasn't terminated yet, * or the Subscribers receive the terminal event (error or completion) if this * Subject has terminated. + *

+ * * * @param the value type received and emitted by this Subject subclass * @since 2.0