Merge #58 into 1.3.0-M2

reactor · May 6, 2024 · c0e400f · c0e400f
2 parents 2e1e928 + 6905a37
commit c0e400f
Show file tree

Hide file tree

Showing 2 changed files with 40 additions and 16 deletions.
diff --git a/src/main/kotlin/reactor/kotlin/extra/retry/RepeatExtensions.kt b/src/main/kotlin/reactor/kotlin/extra/retry/RepeatExtensions.kt
@@ -37,9 +37,13 @@ import java.util.function.Consumer
  *
  * @author Simon Baslé
  * @since 3.1.1
- * @deprecated Reactor-Extra repeat features are being phased out. To be removed at the earliest in 1.3.0.
+ * @deprecated Reactor-Extra repeat features are being phased out. If you still
+ *   need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra repeat features are being phased out.")
+@Deprecated(message = "Reactor-Extra repeat features are being phased out. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras " +
+        "runtime dependency is needed.")
 fun <T> Flux<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Duration? = null,
                                          jitter: Boolean = false,
                                          doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T> {
@@ -65,9 +69,13 @@ fun <T> Flux<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Dura
  *
  * @author Simon Baslé
  * @since 3.1.1
- * @deprecated Reactor-Extra repeat features are being phased out. To be removed at the earliest in 1.3.0.
+ * @deprecated Reactor-Extra repeat features are being phased out. If you still
+ *   need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra repeat features are being phased out.")
+@Deprecated(message = "Reactor-Extra repeat features are being phased out. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras " +
+        "runtime dependency is needed.")
 fun <T> Flux<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null,
                                     doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T> {
     val repeat = Repeat.times<T>(times)
@@ -93,9 +101,13 @@ fun <T> Flux<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration?
  *
  * @author Simon Baslé
  * @since 3.1.1
- * @deprecated Reactor-Extra repeat features are being phased out. To be removed at the earliest in 1.3.0.
+ * @deprecated Reactor-Extra repeat features are being phased out. If you still
+ *   need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra repeat features are being phased out.")
+@Deprecated(message = "Reactor-Extra repeat features are being phased out. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras " +
+        "runtime dependency is needed.")
 fun <T> Mono<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Duration? = null,
                                          jitter: Boolean = false,
                                          doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T> {
@@ -121,9 +133,13 @@ fun <T> Mono<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Dura
  *
  * @author Simon Baslé
  * @since 3.1.1
- * @deprecated Reactor-Extra repeat features are being phased out. To be removed at the earliest in 1.3.0.
+ * @deprecated Reactor-Extra repeat features are being phased out. If you still
+ *   need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra repeat features are being phased out.")
+@Deprecated(message = "Reactor-Extra repeat features are being phased out. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras " +
+        "runtime dependency is needed.")
 fun <T> Mono<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null,
                                     doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T> {
     val repeat = Repeat.times<T>(times)

diff --git a/src/main/kotlin/reactor/kotlin/extra/retry/RetryExtensions.kt b/src/main/kotlin/reactor/kotlin/extra/retry/RetryExtensions.kt
@@ -38,9 +38,11 @@ import java.util.function.Consumer
  * @author Simon Baslé
  * @since 3.1.1
  * @deprecated Reactor-Extra retry features have been replaced by a core alternative and will be removed.
- * To be removed at the earliest in 1.3.0.
+ *   If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.")
+@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.")
 fun <T> Flux<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null,
                                         jitter: Boolean = false,
                                         doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T> {
@@ -68,9 +70,11 @@ fun <T> Flux<T>.retryExponentialBackoff(times: Long, first: Duration, max: Durat
  * @author Simon Baslé
  * @since 3.1.1
  * @deprecated Reactor-Extra retry features have been replaced by a core alternative and will be removed.
- * To be removed at the earliest in 1.3.0.
+ *   If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.")
+@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.")
 fun <T> Flux<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null,
                                    doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T> {
     val retry = Retry.any<T>()
@@ -97,9 +101,11 @@ fun <T> Flux<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration?
  * @author Simon Baslé
  * @since 3.1.1
  * @deprecated Reactor-Extra retry features have been replaced by a core alternative and will be removed.
- * To be removed at the earliest in 1.3.0.
+ *   If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.")
+@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.")
 fun <T> Mono<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null,
                                         jitter: Boolean = false,
                                         doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T> {
@@ -127,9 +133,11 @@ fun <T> Mono<T>.retryExponentialBackoff(times: Long, first: Duration, max: Durat
  * @author Simon Baslé
  * @since 3.1.1
  * @deprecated Reactor-Extra retry features have been replaced by a core alternative and will be removed.
- * To be removed at the earliest in 1.3.0.
+ *   If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.
+ *   To be removed at the earliest in 1.3.0.
  */
-@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed.")
+@Deprecated(message = "Reactor-Extra retry features have been replaced by a core alternative and will be removed. " +
+        "If you still need to call this method, io.projectreactor:reactor-extras runtime dependency is needed.")
 fun <T> Mono<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null,
                                    doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T> {
     val retry = Retry.any<T>()