We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 75a7fc4 commit 73266b3Copy full SHA for 73266b3
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala
@@ -528,7 +528,7 @@ trait Observable[+T]
528
val o1: rx.Observable[_ <: rx.Observable[_]] = asJavaObservable.window[Closing](func)
529
val o2 = Observable[rx.Observable[_]](o1).map((x: rx.Observable[_]) => {
530
val x2 = x.asInstanceOf[rx.Observable[_ <: T]]
531
- Observable[T](x2)
+ toScalaObservable[T](x2)
532
})
533
o2
534
}
0 commit comments