Merge pull request #396 from samuelgruetter/idiomaticscala

Add missing methods to Scala Adaptor

Author: benjchristensen

language-adaptors/rxjava-scala/TODO.md

@@ -4,17 +4,14 @@ TODOs for Scala Adapter
 
 This is a (probably incomplete) list of what still needs to be done in the Scala adaptor:
 
-- [ ] ConnectableObservable: Implement adaptor. Note that it cannot extend Scala Observable, since value classes are final.
-- [ ] more methods of BlockingObservable
-- [ ] multicast, publish, replay once we have ConnectableObservable
-- [ ] groupBy and GroupedObservable
-- [ ] mirror complete Java package structure in Scala
-- [ ] convert Java futures to Scala futures
-- [ ] Add methods present in Scala collections library, but not in RxJava, e.g. zipWithIndex, aggregate à la Scala
-- [ ] mergeDelayError, combineLatest, merge, concat, zip: decide if instance method or static or both, decide about arities > 2
-- [ ] naming: switch() or switchOnNext()?
-- [ ] decide where the MovieLib/MovieLibUsage (use Scala code from Java code) example should live and make sure gradle builds it in the right order
-- [ ] Avoid text duplication in scaladoc using templates, add examples, distinction between use case signature and full signature
-- [ ] other small TODOs
+*    mirror complete Java package structure in Scala
+*    objects for classes with static methods or singletons (e.g. Schedulers, Subscriptions)
+*    Notification as a case class
+*    integrating Scala Futures, should there be a common base interface for Futures and Observables?
+*    Add methods present in Scala collections library, but not in RxJava, e.g. aggregate à la Scala, collect, exists, tails, ...
+*    combineLatest with arities > 2
+*    decide where the MovieLib/MovieLibUsage (use Scala code from Java code) example should live and make sure gradle builds it in the right order
+*    Avoid text duplication in scaladoc using templates, add examples, distinction between use case signature and full signature
+*    other small TODOs
 
 

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/ImplicitFunctionConversions.scala

@@ -73,6 +73,11 @@ object ImplicitFunctionConversions {
     new Func2[A, B, jlang.Boolean] {
       def call(a: A, b: B): jlang.Boolean = f(a, b).booleanValue
     }
+  
+  implicit def scalaFuncNToRxFuncN[R](f: Seq[java.lang.Object] => R): FuncN[R] =
+    new FuncN[R] {
+      def call(args: java.lang.Object*): R = f(args)
+    }
 
   /**
    * Converts a specific function shape (used in takeWhile) to the equivalent Java types with an Rx Func2