Don't need to enable Ratpack/RxJava bridge here.

Author: ldaley

build.sbt

@@ -13,7 +13,6 @@ scalaVersion := "2.11.4"
 libraryDependencies ++= Seq(
     "com.typesafe.akka" %% "akka-stream-experimental" % "0.10-M1",
     "io.reactivex" % "rxjava-reactive-streams" % "0.3.0",
-    "io.ratpack" % "ratpack-rx" % "0.9.10-SNAPSHOT",
     "io.ratpack" % "ratpack-test" % "0.9.10-SNAPSHOT",
     "org.projectreactor" % "reactor-core" % "2.0.0.M1"
   )

src/main/java/com/rolandkuhn/rsinterop/JavaMain.java

@@ -9,7 +9,6 @@
 import akka.stream.javadsl.Sink;
 import akka.stream.javadsl.Source;
 import ratpack.http.ResponseChunks;
-import ratpack.rx.RxRatpack;
 import ratpack.test.embed.EmbeddedApp;import reactor.rx.Stream;
 import reactor.rx.Streams;
 import rx.Observable;
@@ -21,7 +20,6 @@ public class JavaMain {
 	public static void main(String[] args) {
 		final ActorSystem system = ActorSystem.create("InteropTest");
 		final FlowMaterializer mat = FlowMaterializer.create(system);
-		RxRatpack.initialize();
 
 		EmbeddedApp.fromHandler(ctx -> {
 			final Integer[] ints = new Integer[10];

src/main/scala/com/rolandkuhn/rsinterop/ScalaMain.scala

@@ -1,6 +1,5 @@
 package com.rolandkuhn.rsinterop
 
-import ratpack.rx.RxRatpack
 import ratpack.test.embed.EmbeddedApp
 import ratpack.handling.Handler
 import ratpack.handling.Context
@@ -21,8 +20,6 @@ object ScalaMain extends App {
   val system = ActorSystem("InteropTest")
   implicit val mat = FlowMaterializer()(system)
 
-  RxRatpack.initialize()
-  
   EmbeddedApp.fromHandler(new Handler {
     override def handle(ctx: Context): Unit = {
       // RxJava Observable