diff --git a/src/main/scala/reactor/core/scala/publisher/Flux.scala b/src/main/scala/reactor/core/scala/publisher/Flux.scala
index 602d437e..5641b11d 100644
--- 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
index 2cb15d69..95d181a2 100644
--- 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)