Fixed scala compilation error.

ReactiveX · Dec 6, 2013 · d85c15f · d85c15f
1 parent 7729df4
commit d85c15f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala b/language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala
@@ -528,7 +528,7 @@ trait Observable[+T]
     val o1: rx.Observable[_ <: rx.Observable[_]] = asJavaObservable.window[Closing](func)
     val o2 = Observable[rx.Observable[_]](o1).map((x: rx.Observable[_]) => {
       val x2 = x.asInstanceOf[rx.Observable[_ <: T]]
-      Observable[T](x2)
+      toScalaObservable[T](x2)
     })
     o2
   }