From fe406bd8ab78fbdcdb07375c190e593f11370343 Mon Sep 17 00:00:00 2001 From: Aleksandar Simic Date: Mon, 16 Jul 2018 01:26:59 +0200 Subject: [PATCH 1/2] Add marble diagrams for Single.repeat operators --- src/main/java/io/reactivex/Single.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/io/reactivex/Single.java b/src/main/java/io/reactivex/Single.java index 84e96defbb..fd79c57cca 100644 --- a/src/main/java/io/reactivex/Single.java +++ b/src/main/java/io/reactivex/Single.java @@ -2986,6 +2986,8 @@ public final Single onTerminateDetach() { /** * Repeatedly re-subscribes to the current Single and emits each success value. + *

+ * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.
@@ -3004,6 +3006,8 @@ public final Flowable repeat() { /** * Re-subscribes to the current Single at most the given number of times and emits each success value. + *

+ * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.
@@ -3025,6 +3029,8 @@ public final Flowable repeat(long times) { * Re-subscribes to the current Single if * the Publisher returned by the handler function signals a value in response to a * value signalled through the Flowable the handle receives. + *

+ * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer. From a41b8ecb19e23d794c3ca3b9c6be02074af99466 Mon Sep 17 00:00:00 2001 From: Aleksandar Simic Date: Tue, 17 Jul 2018 14:50:04 +0200 Subject: [PATCH 2/2] Use correct marble diagram URLs --- src/main/java/io/reactivex/Single.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/io/reactivex/Single.java b/src/main/java/io/reactivex/Single.java index fd79c57cca..3b3a8dc5b5 100644 --- a/src/main/java/io/reactivex/Single.java +++ b/src/main/java/io/reactivex/Single.java @@ -2987,7 +2987,7 @@ public final Single onTerminateDetach() { /** * Repeatedly re-subscribes to the current Single and emits each success value. *

- * + * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.
@@ -3007,7 +3007,7 @@ public final Flowable repeat() { /** * Re-subscribes to the current Single at most the given number of times and emits each success value. *

- * + * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.
@@ -3030,7 +3030,7 @@ public final Flowable repeat(long times) { * the Publisher returned by the handler function signals a value in response to a * value signalled through the Flowable the handle receives. *

- * + * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.