Java example using Scala Observable code

Author: samuelgruetter

language-adaptors/rxjava-scala-java/README.md

@@ -0,0 +1,5 @@
+
+rxjava-scala-java
+-----------------
+
+Contains examples illustrating how RxScala code can be used from Java.

language-adaptors/rxjava-scala-java/build.gradle

@@ -0,0 +1,32 @@
+
+apply plugin: 'osgi'
+
+
+project(':language-adaptors:rxjava-scala-java') {
+    //sourceSets.test.java.srcDir 'src/examples/java'
+    sourceSets.main.java.srcDir 'src/main/java'
+}
+
+dependencies {
+    compile 'org.scala-lang:scala-library:2.10.+'
+
+    compile project(':rxjava-core')
+    
+    compile project(':language-adaptors:rxjava-scala')
+    
+    provided 'junit:junit-dep:4.10'
+    provided 'org.mockito:mockito-core:1.8.5'
+    provided 'org.scalatest:scalatest_2.10:1.9.1'
+}
+
+jar {
+    manifest {
+        name = 'rxjava-scala-java'
+        instruction 'Bundle-Vendor', 'Netflix'
+        instruction 'Bundle-DocURL', 'https://github.com/Netflix/RxJava'
+        instruction 'Import-Package', '!org.junit,!junit.framework,!org.mockito.*,*'
+        instruction 'Fragment-Host', 'com.netflix.rxjava.core'
+    }
+}
+
+

language-adaptors/rxjava-scala-java/src/main/java/rx/lang/scalaexamples/MovieLibUsage.java

@@ -0,0 +1,24 @@
+package rx.lang.scalatests;
+
+import org.junit.Test;
+
+import rx.Observable;
+import rx.util.functions.Action1;
+
+
+public class MovieLibUsage {
+	
+	Action1<Movie> moviePrinter = new Action1<Movie>() {
+		public void call(Movie m) {
+			System.out.println("A movie of length " + m.lengthInSeconds() + "s");
+		}
+	};
+	
+	@Test
+	public void test() {
+		MovieLib lib = new MovieLib(Observable.from(new Movie(3000), new Movie(1000), new Movie(2000)));
+		
+		lib.longMovies().subscribe(moviePrinter);		
+	}
+
+}

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scalatests/MovieLib.scala

@@ -0,0 +1,15 @@
+package rx.lang.scalatests
+
+import rx.lang.scala.Observable
+
+class Movie(val lengthInSeconds: Int) { }
+
+class MovieLib(val moviesStream: Observable[Movie]) {
+  
+  val threshold = 1200
+  
+  def shortMovies: Observable[Movie] = moviesStream.filter(_.lengthInSeconds <= threshold)
+  
+  def longMovies: Observable[Movie] = moviesStream.filter(_.lengthInSeconds > threshold)
+
+}

language-adaptors/rxjava-scala/src/test/scala/rx/lang/scalatests/RxScalaDemo.scala renamed to language-adaptors/rxjava-scala/src/main/scala/rx/lang/scalatests/RxScalaDemo.scala

@@ -3,5 +3,6 @@ include 'rxjava-core', \
 'language-adaptors:rxjava-groovy', \
 'language-adaptors:rxjava-clojure', \
 'language-adaptors:rxjava-scala', \
+'language-adaptors:rxjava-scala-java', \
 'rxjava-contrib:rxjava-swing', \
 'rxjava-contrib:rxjava-android'