Skip to content

Commit 02511c0

Browse files
Publish signature
Less variance, more type inference
1 parent fc86f8c commit 02511c0

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1643,10 +1643,10 @@ trait Observable[+T]
16431643
* @return an Observable that emits the results of invoking the selector on the items emitted by a `ConnectableObservable`
16441644
* that shares a single subscription to the underlying sequence
16451645
*/
1646-
def publish[U >: T, R](selector: Observable[U] => Observable[R]): Observable[R] = {
1647-
val thisJava = this.asJavaObservable.asInstanceOf[rx.Observable[U]]
1648-
val fJava: Func1[rx.Observable[U], rx.Observable[R]] =
1649-
(jo: rx.Observable[U]) => selector(toScalaObservable[U](jo)).asJavaObservable.asInstanceOf[rx.Observable[R]]
1646+
def publish[R](selector: Observable[T] => Observable[R]): Observable[R] = {
1647+
val thisJava = this.asJavaObservable.asInstanceOf[rx.Observable[T]]
1648+
val fJava: Func1[rx.Observable[T], rx.Observable[R]] =
1649+
(jo: rx.Observable[T]) => selector(toScalaObservable[T](jo)).asJavaObservable.asInstanceOf[rx.Observable[R]]
16501650
toScalaObservable[R](thisJava.publish(fJava))
16511651
}
16521652

0 commit comments

Comments
 (0)