Eliminate compiler warnings

Author: zsxwing

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

@@ -555,11 +555,10 @@ class RxScalaDemo extends JUnitSuite {
    * all elements are calculated.
    */
   @Test def createExampleBad() {
-    val o = Observable.create[String](observer => {
+    val o = Observable[String](observer => {
       observer.onNext(calculateElement(0))
       observer.onNext(calculateElement(1))
       observer.onCompleted()
-      Subscription {}
     })
     o.take(1).subscribe(println(_))
   }

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

@@ -21,6 +21,7 @@ import rx.Observable.OnSubscribeFunc
 import rx.lang.scala.observables.ConnectableObservable
 import scala.concurrent.duration
 import java.util
+import java.util.concurrent.TimeUnit
 import collection.JavaConversions._
 
 
@@ -2968,9 +2969,8 @@ trait Observable[+T]
    * @return an Observable that emits time interval information items
    */
   def timeInterval: Observable[(Duration, T)] = {
-    import scala.concurrent.duration.DurationLong
     toScalaObservable(asJavaObservable.timeInterval())
-      .map(inv => (inv.getIntervalInMilliseconds millis, inv.getValue))
+      .map(inv => (Duration(inv.getIntervalInMilliseconds, TimeUnit.MILLISECONDS), inv.getValue))
   }
 
   /**
@@ -2983,9 +2983,8 @@ trait Observable[+T]
    * @return an Observable that emits time interval information items
    */
   def timeInterval(scheduler: Scheduler): Observable[(Duration, T)] = {
-    import scala.concurrent.duration.DurationLong
     toScalaObservable(asJavaObservable.timeInterval(scheduler.asJavaScheduler))
-      .map(inv => (inv.getIntervalInMilliseconds millis, inv.getValue))
+      .map(inv => (Duration(inv.getIntervalInMilliseconds, TimeUnit.MILLISECONDS), inv.getValue))
   }
 
   /**