File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -1664,7 +1664,6 @@ trait Observable[+T]
1664
1664
* @return an Observable that emits `initialValue` followed by the results of invoking the selector
1665
1665
* on a `ConnectableObservable` that shares a single subscription to the underlying Observable
1666
1666
*/
1667
- import annotation .unchecked ._
1668
1667
def publish [R ](selector : Observable [T ] => Observable [R ], initialValue : T @ uncheckedVariance): Observable [R ] = {
1669
1668
val thisJava = this .asJavaObservable.asInstanceOf [rx.Observable [T ]]
1670
1669
val fJava : Func1 [rx.Observable [T ], rx.Observable [R ]] =
@@ -2884,7 +2883,7 @@ trait Observable[+T]
2884
2883
* @return an Observable that emits only the very first item from the source, or a default value
2885
2884
* if the source Observable completes without emitting any item.
2886
2885
*/
2887
- def headOrElse (default : => T @ uncheckedVariance ): Observable [T ] = firstOrElse(default)
2886
+ def headOrElse [ U >: T ] (default : => U ): Observable [U ] = firstOrElse(default)
2888
2887
2889
2888
/**
2890
2889
* Returns an Observable that emits only the very first item emitted by the source Observable, or raises an
You can’t perform that action at this time.
0 commit comments