Skip to content

Commit df18366

Browse files
committed
Fix the compose generics in RxScala
1 parent 07f4d90 commit df18366

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,8 @@ object JavaConversions {
6565

6666
implicit def toJavaTransformer[T, R](transformer: Observable[T] => Observable[R]): rx.Observable.Transformer[T, R] = {
6767
new rx.Observable.Transformer[T, R] {
68-
override def call(o: rx.Observable[_ <: T]): rx.Observable[R] = {
69-
transformer(toScalaObservable(o)).asJavaObservable.asInstanceOf[rx.Observable[R]]
68+
override def call(o: rx.Observable[_ <: T]): rx.Observable[_ <: R] = {
69+
transformer(toScalaObservable(o)).asJavaObservable
7070
}
7171
}
7272
}

0 commit comments

Comments
 (0)