Fixed Mono.name

Signed-off-by: Winarto Zhao <[email protected]>

Author: sinwe

src/main/scala/reactor/core/scala/publisher/Mono.scala

@@ -19,16 +19,16 @@
 package reactor.core.scala.publisher
 
 import java.lang.{Boolean => JBoolean, Iterable => JIterable, Long => JLong}
-import java.time.{Duration => JDuration}
 import java.util.concurrent.{Callable, CompletableFuture}
-import java.util.function.{BiConsumer, BiFunction, BiPredicate, Consumer, Function, Predicate, Supplier}
+import java.util.function.{BiPredicate, Consumer, Function, Predicate, Supplier}
 import java.util.logging.Level
 
 import org.reactivestreams.{Publisher, Subscriber, Subscription}
-import reactor.core.Disposable
-import reactor.core.publisher.{MonoProcessor, MonoSink, Signal, SignalType, SynchronousSink, Flux => JFlux, Mono => JMono}
+import reactor.core.publisher.{MonoSink, Signal, SignalType, SynchronousSink, Flux => JFlux, Mono => JMono}
+import reactor.core.scala.Scannable
 import reactor.core.scala.publisher.PimpMyPublisher._
 import reactor.core.scheduler.Scheduler
+import reactor.core.{Disposable, Scannable => JScannable}
 import reactor.util.context.Context
 import reactor.util.function._
 
@@ -63,9 +63,11 @@ import scala.util.{Failure, Success, Try}
   * @see Flux
   */
 class Mono[T] private(private val jMono: JMono[T])
-  extends Publisher[T] with MapablePublisher[T] with OnErrorReturn[T] with MonoLike[T] with Filter[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 = jMono.subscribe(s)
 
+  override def jScannable: JScannable = JScannable.from(jMono)
+
   /**
     * Transform this [[Mono]] into a target type.
     *

src/test/scala/reactor/core/scala/publisher/FluxTest.scala

@@ -1574,7 +1574,7 @@ class FluxTest extends FreeSpec with Matchers with TableDrivenPropertyChecks wit
         .verifyComplete()
     }
 
-    ".name should call the underlying Flux.name method" in {
+    ".name should name the sequence" in {
       val name = "flux integer"
       val flux = Flux.just(1, 2, 3, 4).name(name)
       val scannable: Scannable = Scannable.from(Option(flux))

src/test/scala/reactor/core/scala/publisher/MonoTest.scala

@@ -12,6 +12,7 @@ import org.scalatest.prop.TableDrivenPropertyChecks
 import org.scalatest.{AsyncFreeSpec, FreeSpec, Matchers}
 import reactor.core.Disposable
 import reactor.core.publisher.{BaseSubscriber, Signal, SynchronousSink, Flux => JFlux, Mono => JMono}
+import reactor.core.scala.Scannable
 import reactor.core.scala.publisher.Mono.just
 import reactor.core.scheduler.{Scheduler, Schedulers}
 import reactor.test.StepVerifier
@@ -206,11 +207,11 @@ class MonoTest extends FreeSpec with Matchers with TableDrivenPropertyChecks wit
       }
     }
 
-    ".name should call the underlying Mono.name method" in {
-      val jMono = spy(JMono.just(1))
-      val mono = Mono(jMono)
-      mono.name("mono-integer")
-      verify(jMono).name("mono-integer")
+    ".name should name the sequence" in {
+      val name = "mono integer"
+      val mono = Mono.just(randomValue).name(name)
+      val scannable: Scannable = Scannable.from(Option(mono))
+      scannable.name shouldBe name
     }
 
     ".never will never signal any data, error or completion signal" in {