Deprecated Flux and Mono

spring-attic · Jun 12, 2019 · 9a944ec · 9a944ec
1 parent 9715e3a
commit 9a944ec
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/main/scala/reactor/core/scala/publisher/Flux.scala b/src/main/scala/reactor/core/scala/publisher/Flux.scala
@@ -42,7 +42,9 @@ import scala.concurrent.duration.Duration
   *
   * @tparam T the element type of this Reactive Streams [[Publisher]]
   * @see [[Mono]]
+  * @deprecated Use [[SFlux]]
   */
+@deprecated(message = "This class is deprecated. Use SFlux", since = "0.4.0")
 class Flux[T] private[publisher](private[publisher] val jFlux: JFlux[T])
   extends Publisher[T] with MapablePublisher[T] with OnErrorReturn[T] with FluxLike[T] with Filter [T] with Scannable {
 

diff --git a/src/main/scala/reactor/core/scala/publisher/Mono.scala b/src/main/scala/reactor/core/scala/publisher/Mono.scala
@@ -61,7 +61,9 @@ import scala.util.{Failure, Success, Try}
   *
   * @tparam T the type of the single value of this class
   * @see Flux
+  * @deprecated Use [[SMono]]
   */
+@deprecated(message = "This class is deprecated, use SMono", since = "0.4.0")
 class Mono[T] private(private val jMono: JMono[T])
   extends Publisher[T] with MapablePublisher[T] with OnErrorReturn[T] with MonoLike[T] with Filter[T] with Scannable {
   override def subscribe(s: Subscriber[_ >: T]): Unit = new ReactiveSMono[T](jMono).subscribe(s)