Added test .asJava

Opened up Mono.apply and Flux.apply for converting java to scala
Upgrade scala version to 2.11.11

gradle.properties

@@ -1,2 +1,2 @@
 version=0.3.1-SNAPSHOT
-scalaVersions=2.11.9
+scalaVersions=2.11.11

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

@@ -3984,7 +3984,7 @@ class Flux[T] private[publisher](private[publisher] val jFlux: JFlux[T]) extends
 
 object Flux {
 
-  private[publisher] def apply[T](jFlux: JFlux[T]): Flux[T] = new Flux[T](jFlux)
+  def apply[T](jFlux: JFlux[T]): Flux[T] = new Flux[T](jFlux)
 
   /**
     * Build a [[Flux]] whose data are generated by the combination of the most recent published values from all

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

@@ -404,6 +404,16 @@ class Mono[T] private(private val jMono: JMono[T]) extends Publisher[T] with Map
     )
   }
 
+  /**
+    * Add behavior triggered when the [[Mono]] emits a data successfully.
+    *
+    * <p>
+    * <img class="marble" src="https://raw.githubusercontent.com/reactor/reactor-core/v3.1.0.RC1/src/docs/marble/doonnext.png" alt="">
+    * <p>
+    *
+    * @param onNext the callback to call on [[Subscriber.onNext]]
+    * @return a new [[Mono]]
+    */
   final def doOnNext(onNext: (T => Unit)): Mono[T] = {
     val onNextFunction = new Consumer[T] {
       override def accept(t: T): Unit = onNext(t)

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

@@ -2042,5 +2042,15 @@ class FluxTest extends FreeSpec with Matchers with TableDrivenPropertyChecks {
           .verifyComplete()
       }
     }
+
+    ".asJava should convert to java" in {
+      val flux = Flux.just(1, 2, 3).asJava()
+      flux shouldBe a[reactor.core.publisher.Flux[_]]
+    }
+
+    ".apply should convert to scala" in {
+      val flux = Flux(reactor.core.publisher.Flux.just(1, 2, 3))
+      flux shouldBe a[Flux[_]]
+    }
   }
 }

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

@@ -471,7 +471,7 @@ class MonoTest extends FreeSpec with Matchers with TableDrivenPropertyChecks wit
     }
 
     ".delayUntil should delay until the other provider terminate" in {
-      StepVerifier.withVirtualTime(() => Mono.just(randomValue).delayUntil(t => Flux.just(1, 2).delayElements(2 seconds)))
+      StepVerifier.withVirtualTime(() => Mono.just(randomValue).delayUntil(_ => Flux.just(1, 2).delayElements(2 seconds)))
         .thenAwait(4 seconds)
         .expectNext(randomValue)
         .verifyComplete()
@@ -1162,6 +1162,16 @@ class MonoTest extends FreeSpec with Matchers with TableDrivenPropertyChecks wit
         .expectNext(randomValue.toString)
         .verifyComplete()
     }
+
+    ".asJava should convert to java" in {
+      val mono = Mono.just(randomValue).asJava()
+      mono shouldBe a[JMono[_]]
+    }
+
+    ".apply should convert to scala" in {
+      val mono = Mono(JMono.just(randomValue))
+      mono shouldBe a[Mono[_]]
+    }
   }