diff --git a/src/main/java/io/reactivex/Observable.java b/src/main/java/io/reactivex/Observable.java index bae61e9cf0..83b807371b 100644 --- a/src/main/java/io/reactivex/Observable.java +++ b/src/main/java/io/reactivex/Observable.java @@ -7300,7 +7300,7 @@ public final Observable doOnSubscribe(Consumer onSubscrib * Modifies the source ObservableSource so that it invokes an action when it calls {@code onComplete} or * {@code onError}. *

- * + * *

* This differs from {@code doAfterTerminate} in that this happens before the {@code onComplete} or * {@code onError} notification. @@ -7328,7 +7328,7 @@ public final Observable doOnTerminate(final Action onTerminate) { * Returns a Maybe that emits the single item at a specified index in a sequence of emissions from * this Observable or completes if this Observable signals fewer elements than index. *

- * + * *

*
Scheduler:
*
{@code elementAt} does not operate by default on a particular {@link Scheduler}.
@@ -7355,7 +7355,7 @@ public final Maybe elementAt(long index) { * Returns a Single that emits the item found at a specified index in a sequence of emissions from * this Observable, or a default item if that index is out of range. *

- * + * *

*
Scheduler:
*
{@code elementAt} does not operate by default on a particular {@link Scheduler}.
@@ -7385,7 +7385,7 @@ public final Single elementAt(long index, T defaultItem) { * Returns a Single that emits the item found at a specified index in a sequence of emissions from this Observable * or signals a {@link NoSuchElementException} if this Observable signals fewer elements than index. *

- * + * *

*
Scheduler:
*
{@code elementAtOrError} does not operate by default on a particular {@link Scheduler}.
@@ -7435,7 +7435,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}.
@@ -7475,7 +7475,7 @@ public final Single first(T defaultItem) { * Returns a Single that emits only the very first item emitted by this Observable or * signals a {@link NoSuchElementException} if this Observable is empty. *

- * + * *

*
Scheduler:
*
{@code firstOrError} does not operate by default on a particular {@link Scheduler}.
@@ -7521,7 +7521,7 @@ public final Observable flatMap(Function - * + * *
*
Scheduler:
*
{@code flatMap} does not operate by default on a particular {@link Scheduler}.
@@ -7550,8 +7550,8 @@ public final Observable flatMap(Function --> - * + *

+ * *

*
Scheduler:
*
{@code flatMap} does not operate by default on a particular {@link Scheduler}.
@@ -7583,8 +7583,8 @@ public final Observable flatMap(Function --> - * + *

+ * *

*
Scheduler:
*
{@code flatMap} does not operate by default on a particular {@link Scheduler}.
@@ -7707,8 +7707,8 @@ public final Observable flatMap( * by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting * ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent * subscriptions to these ObservableSources. - * - * + *

+ * *

*
Scheduler:
*
{@code flatMap} does not operate by default on a particular {@link Scheduler}.