From c9c9be7e847b23d411085375e1d16981d6719c93 Mon Sep 17 00:00:00 2001 From: akarnokd Date: Wed, 18 Oct 2017 13:45:17 +0200 Subject: [PATCH] 2.x: More Observable marble fixes (10/18) --- src/main/java/io/reactivex/Observable.java | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/src/main/java/io/reactivex/Observable.java b/src/main/java/io/reactivex/Observable.java index fac498aaf1..38baae0931 100644 --- a/src/main/java/io/reactivex/Observable.java +++ b/src/main/java/io/reactivex/Observable.java @@ -4689,7 +4689,7 @@ public static Observable zipArray(Function} passed to the method would trigger a {@code ClassCastException}. * *

- * + * *

*
Scheduler:
*
{@code zipIterable} does not operate by default on a particular {@link Scheduler}.
@@ -4752,7 +4752,7 @@ public final Single all(Predicate predicate) { * Mirrors the ObservableSource (current or provided) that first either emits an item or sends a termination * notification. *

- * + * *

*
Scheduler:
*
{@code ambWith} does not operate by default on a particular {@link Scheduler}.
@@ -4854,7 +4854,7 @@ public final T blockingFirst(T defaultItem) { *

* Note: This will block even if the underlying Observable is asynchronous. *

- * + * *

* This is similar to {@link Observable#subscribe(Observer)}, but it blocks. Because it blocks it does not * need the {@link Observer#onComplete()} or {@link Observer#onError(Throwable)} methods. If the @@ -4892,7 +4892,7 @@ public final void blockingForEach(Consumer onNext) { /** * Converts this {@code Observable} into an {@link Iterable}. *

- * + * *

*
Scheduler:
*
{@code blockingIterable} does not operate by default on a particular {@link Scheduler}.
@@ -4931,7 +4931,7 @@ public final Iterable blockingIterable(int bufferSize) { * Returns the last item emitted by this {@code Observable}, or throws * {@code NoSuchElementException} if this {@code Observable} emits no items. *

- * + * *

*
Scheduler:
*
{@code blockingLast} does not operate by default on a particular {@link Scheduler}.
@@ -4958,7 +4958,7 @@ public final T blockingLast() { * Returns the last item emitted by this {@code Observable}, or a default value if it emits no * items. *

- * + * *

*
Scheduler:
*
{@code blockingLast} does not operate by default on a particular {@link Scheduler}.
@@ -5006,7 +5006,7 @@ public final Iterable blockingLatest() { * Returns an {@link Iterable} that always returns the item most recently emitted by this * {@code Observable}. *

- * + * *

*
Scheduler:
*
{@code blockingMostRecent} does not operate by default on a particular {@link Scheduler}.
@@ -5029,7 +5029,7 @@ public final Iterable blockingMostRecent(T initialValue) { * Returns an {@link Iterable} that blocks until this {@code Observable} emits another item, then * returns that item. *

- * + * *

*
Scheduler:
*
{@code blockingNext} does not operate by default on a particular {@link Scheduler}.
@@ -5049,7 +5049,7 @@ public final Iterable blockingNext() { * If this {@code Observable} completes after emitting a single item, return that item, otherwise * throw a {@code NoSuchElementException}. *

- * + * *

*
Scheduler:
*
{@code blockingSingle} does not operate by default on a particular {@link Scheduler}.
@@ -5073,7 +5073,7 @@ public final T blockingSingle() { * more than one item, throw an {@code IllegalArgumentException}; if it emits no items, return a default * value. *

- * + * *

*
Scheduler:
*
{@code blockingSingle} does not operate by default on a particular {@link Scheduler}.
@@ -5854,7 +5854,7 @@ public final Observable cache() { * Returns an Observable that subscribes to this ObservableSource lazily, caches all of its events * and replays them, in the same order as received, to all the downstream subscribers. *

- * + * *

* This is useful when you want an ObservableSource to cache responses and you can't control the * subscribe/dispose behavior of all the {@link Observer}s.