changes from review + scaladoc improvements

Author: samuelgruetter

language-adaptors/rxjava-scala/TODO.md

@@ -7,7 +7,16 @@ This is a (probably incomplete) list of what still needs to be done in the Scala
 *    Integrating Scala Futures: Should there be a common base interface for Futures and Observables? And if all subscribers of an Observable wrapping a Future unsubscribe, the Future should be cancelled, but Futures do not support cancellation.
 *    Add methods present in Scala collections library, but not in RxJava, e.g. aggregate à la Scala, collect, tails, ...
 *    combineLatest with arities > 2
+*    Implicit schedulers?
 *    Avoid text duplication in scaladoc using templates, add examples, distinction between use case signature and full signature
 *    other small TODOs
 
 
+(Implicit) schedulers for interval: Options:
+
+```scala
+def interval(duration: Duration)(implicit scheduler: Scheduler): Observable[Long]
+def interval(duration: Duration)(scheduler: Scheduler): Observable[Long]
+def interval(scheduler: Scheduler)(duration: Duration): Observable[Long]
+def interval(duration: Duration, scheduler: Scheduler): Observable[Long] && def interval(duration: Duration): Observable[Long] 
+````

language-adaptors/rxjava-scala/src/examples/scala/rx/lang/scala/examples/RxScalaDemo.scala

@@ -323,13 +323,13 @@ class RxScalaDemo extends JUnitSuite {
         .toBlockingObservable.foreach(println(_))
   }
 
-  // source Observables are in a List:
-  @Test def zipManySeqExample() {
-    val observables = List(Observable(1, 2), Observable(10, 20), Observable(100, 200))
-    (for (seq <- Observable.zip(observables)) yield seq.mkString("(", ", ", ")"))
+  // source Observables are all known:
+  @Test def zip3Example() {
+    val o = Observable.zip(Observable(1, 2), Observable(10, 20), Observable(100, 200))
+    (for ((n1, n2, n3) <- o) yield s"$n1, $n2 and $n3")
         .toBlockingObservable.foreach(println(_))
   }
-  
+
   // source Observables are in an Observable:
   @Test def zipManyObservableExample() {
     val observables = Observable(Observable(1, 2), Observable(10, 20), Observable(100, 200))
@@ -453,7 +453,7 @@ class RxScalaDemo extends JUnitSuite {
 
     Thread.sleep(1500) // or convert to BlockingObservable
   }
-  
+
   def output(s: String): Unit = println(s)
 
   // blocks until obs has completed