Version 0.10.0 - Static Language Support

build.gradle

@@ -1,3 +1,9 @@
+apply from: file('gradle/convention.gradle')
+apply from: file('gradle/maven.gradle')
+//apply from: file('gradle/check.gradle')
+apply from: file('gradle/license.gradle')
+apply from: file('gradle/release.gradle')
+
 ext.githubProjectName = rootProject.name
 
 buildscript {
@@ -9,20 +15,53 @@ allprojects {
     repositories { mavenCentral() }
 }
 
-apply from: file('gradle/convention.gradle')
-apply from: file('gradle/maven.gradle')
-//apply from: file('gradle/check.gradle')
-apply from: file('gradle/license.gradle')
-apply from: file('gradle/release.gradle')
-
 subprojects {
+    apply plugin: 'java'
+    apply plugin: 'eclipse'
+    apply plugin: 'idea'
 
     group = "com.netflix.${githubProjectName}"
 
-    sourceSets.test.java.srcDir 'src/main/java'
+    ext.codeGenOutputDir = file("build/rewritten_classes")
+
+    // make 'examples' use the same classpath
+    configurations { 
+        core
+        examplesCompile.extendsFrom compile
+        examplesRuntime.extendsFrom runtime
+    }
+
+    sourceSets.test.java.srcDirs.add('src/main/java')
 
     tasks.withType(Javadoc).each {
         it.classpath = sourceSets.main.compileClasspath
     }
+
+    sourceSets { 
+        //include /src/examples folder
+        examples
+    }
+
+    // include 'examples' in build task
+    tasks.build { 
+        dependsOn(examplesClasses)
+    }
+
+    eclipse { 
+        classpath { 
+            // include 'provided' dependencies on the classpath
+            plusConfigurations += configurations.provided
+
+            downloadSources = true
+            downloadJavadoc = true
+        }
+    }
+
+    idea {
+        module {
+            // include 'provided' dependencies on the classpath
+            scopes.PROVIDED.plus += configurations.provided
+        }
+    }
 }
 

gradle.properties

@@ -1 +1 @@
-version=0.9.2-SNAPSHOT
+version=0.10.0-SNAPSHOT

gradle/wrapper/gradle-wrapper.properties

@@ -3,4 +3,4 @@ distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=http\://services.gradle.org/distributions/gradle-1.3-bin.zip
+distributionUrl=http\://services.gradle.org/distributions/gradle-1.6-bin.zip

language-adaptors/codegen/build.gradle

@@ -0,0 +1,24 @@
+apply plugin: 'java'
+apply plugin: 'groovy'
+apply plugin: 'eclipse'
+apply plugin: 'idea'
+apply plugin: 'osgi'
+
+dependencies { 
+    compile project(':rxjava-core')
+    compile 'org.javassist:javassist:3.17.1-GA'
+
+    provided 'junit:junit:4.10'
+}
+
+jar {
+    exclude('**/*$UnitTest*')
+
+    manifest {
+        name = 'rxjava-codegen'
+        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/codegen/examples.txt

@@ -0,0 +1,47 @@
+Here's the example source of Observable (heavily elided):
+
+public class rx.Observable {
+    public static <T> Observable<T> create(Func1<Observer<T>, Subscription> func) {
+        return new Observable<T>(func);
+    }
+
+    public static <T> Observable<T> create(Object func) {
+        ...
+    }
+
+    public static <T> Observable<T> take(final Observable<T> items, final int num) {
+        return create(OperationTake.take(items, num));
+    }
+
+    public static <T> Observable<T> takeWhile(final Observable<T> items, Func1<T, Boolean> predicate) {
+        return create(OperationTakeWhile.takeWhile(items, predicate));
+    }
+
+    public Observable<T> filter(Func1<T, Boolean> predicate) {
+        return filter(this, predicate);
+    }
+
+    public static <T> Observable<T> filter(Observable<T> that, Func1<T, Boolean> predicate) {
+        return create(OperationFilter.filter(that, predicate));
+    }
+}
+
+Groovy-friendly version adds:
+
+public class rx.Observable {
+    public static <T> rx.Observable<T> create(groovy.lang.Closure func) {
+        return create(new GroovyFunctionAdaptor(func));
+    }
+
+    public static <T> rx.Observable<T> takeWhile(final Observable<T> items, groovy.lang.Closure predicate) {
+        return takeWhile(items, new GroovyFunctionAdaptor(predicate));
+    }
+
+    public rx.Observable<T> filter(groovy.lang.Closure predicate) {
+        return filter(new GroovyFunctionAdaptor(predicate));
+    }
+
+    public static <T> rxObservable<T> filter(Observable<T> that, groovy.lang.Closure predicate) {
+        return filter(that, new GroovyFunctionAdaptor(predicate));
+    }
+}

language-adaptors/codegen/src/main/java/rx/codegen/ClassPathBasedRunner.java

@@ -0,0 +1,64 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package rx.codegen;
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.List;
+
+import rx.util.functions.FunctionLanguageAdaptor;
+
+public class ClassPathBasedRunner {
+    public static void main(String[] args) {
+        if (args.length != 2) {
+            System.out.println("Usage : Expects 2 args: (Language, File to place classfiles)");
+            System.out.println("Currently supported languages: Groovy/Clojure/JRuby");
+            System.exit(1);
+        }
+        String lang = args[0];
+        File dir = new File(args[1]);
+        System.out.println("Looking for Adaptor for : " + lang);
+        String className = "rx.lang." + lang.toLowerCase() + "." + lang + "Adaptor";
+        try {
+            Class<?> adaptorClass = Class.forName(className);
+            System.out.println("Found Adaptor : " + adaptorClass);
+            FunctionLanguageAdaptor adaptor = (FunctionLanguageAdaptor) adaptorClass.newInstance();
+
+            CodeGenerator codeGen = new CodeGenerator(); 
+            System.out.println("Using dir : " + dir + " for outputting classfiles");
+            for (Class<?> observableClass: getObservableClasses()) {
+                codeGen.addMethods(observableClass, adaptor, new File(args[1]));
+            }
+        } catch (ClassNotFoundException ex) {
+            System.out.println("Did not find adaptor class : " + className);
+            System.exit(1);
+        } catch (InstantiationException ex) {
+            System.out.println("Reflective constuctor on : " + className + " failed");
+            System.exit(1);
+        } catch (IllegalAccessException ex) {
+            System.out.println("Access to constructor on : " + className + " failed");
+            System.exit(1);
+        }
+    }
+
+    private static List<Class<?>> getObservableClasses() {
+        List<Class<?>> observableClasses = new ArrayList<Class<?>>();
+        observableClasses.add(rx.Observable.class);
+        observableClasses.add(rx.observables.BlockingObservable.class);
+        return observableClasses;
+    }
+}