From 927eff69cddf7548e2a0e118eacd9b1e67dc0d70 Mon Sep 17 00:00:00 2001 From: akarnokd Date: Tue, 28 Nov 2017 11:40:27 +0100 Subject: [PATCH] 2.x: add/update Observable marbles 11/28 --- src/main/java/io/reactivex/Observable.java | 26 ++++++++++++++++------ 1 file changed, 19 insertions(+), 7 deletions(-) diff --git a/src/main/java/io/reactivex/Observable.java b/src/main/java/io/reactivex/Observable.java index f6f1082a92..fac04781e7 100644 --- a/src/main/java/io/reactivex/Observable.java +++ b/src/main/java/io/reactivex/Observable.java @@ -4827,6 +4827,8 @@ public final R as(@NonNull ObservableConverter converter) { /** * Returns the first item emitted by this {@code Observable}, or throws * {@code NoSuchElementException} if it emits no items. + *

+ * *

*
Scheduler:
*
{@code blockingFirst} does not operate by default on a particular {@link Scheduler}.
@@ -4852,6 +4854,8 @@ public final T blockingFirst() { /** * Returns the first item emitted by this {@code Observable}, or a default value if it emits no * items. + *

+ * *

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

* If the {@code Observable} may emit more than one item, use {@code Observable.toList().toFuture()}. *

- * + * *

*
Scheduler:
*
{@code toFuture} does not operate by default on a particular {@link Scheduler}.
@@ -5141,6 +5145,8 @@ public final Future toFuture() { /** * Runs the source observable to a terminal event, ignoring any values and rethrowing any exception. + *

+ * *

*
Scheduler:
*
{@code blockingSubscribe} does not operate by default on a particular {@link Scheduler}.
@@ -5155,6 +5161,8 @@ public final void blockingSubscribe() { /** * Subscribes to the source and calls the given callbacks on the current thread. *

+ * + *

* If the Observable emits an error, it is wrapped into an * {@link io.reactivex.exceptions.OnErrorNotImplementedException OnErrorNotImplementedException} * and routed to the RxJavaPlugins.onError handler. @@ -5172,6 +5180,8 @@ public final void blockingSubscribe(Consumer onNext) { /** * Subscribes to the source and calls the given callbacks on the current thread. + *

+ * *

*
Scheduler:
*
{@code blockingSubscribe} does not operate by default on a particular {@link Scheduler}.
@@ -5188,6 +5198,8 @@ public final void blockingSubscribe(Consumer onNext, Consumeron the current thread. + *

+ * *

*
Scheduler:
*
{@code blockingSubscribe} does not operate by default on a particular {@link Scheduler}.
@@ -5991,7 +6003,7 @@ public final Single collect(Callable initialValueSupplier, B * Collects items emitted by the source ObservableSource into a single mutable data structure and returns * a Single that emits this structure. *

- * + * *

* This is a simplified version of {@code reduce} that does not need to return the state on each pass. *

@@ -7053,7 +7065,7 @@ public final Observable doFinally(Action onFinally) { * If the action throws a runtime exception, that exception is rethrown by the {@code dispose()} call, * sometimes as a {@code CompositeException} if there were multiple exceptions along the way. *

- * + * *

*
Scheduler:
*
{@code doOnDispose} does not operate by default on a particular {@link Scheduler}.
@@ -7074,7 +7086,7 @@ public final Observable doOnDispose(Action onDispose) { /** * Modifies the source ObservableSource so that it invokes an action when it calls {@code onComplete}. *

- * + * *

*
Scheduler:
*
{@code doOnComplete} does not operate by default on a particular {@link Scheduler}.
@@ -7177,7 +7189,7 @@ public final Observable doOnEach(final Observer observer) { * In case the {@code onError} action throws, the downstream will receive a composite exception containing * the original exception and the exception thrown by {@code onError}. *

- * + * *

*
Scheduler:
*
{@code doOnError} does not operate by default on a particular {@link Scheduler}.
@@ -7198,7 +7210,7 @@ public final Observable doOnError(Consumer onError) { * Calls the appropriate onXXX method (shared between all Observer) for the lifecycle events of * the sequence (subscription, cancellation, requesting). *

- * + * *

*
Scheduler:
*
{@code doOnLifecycle} does not operate by default on a particular {@link Scheduler}.
@@ -7222,7 +7234,7 @@ public final Observable doOnLifecycle(final Consumer onSu /** * Modifies the source ObservableSource so that it invokes an action when it calls {@code onNext}. *

- * + * *

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