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 6e6f23e commit 3036023Copy full SHA for 3036023
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala
@@ -1839,7 +1839,7 @@ trait Observable[+T]
1839
* @return an Observable with the side-effecting behavior applied.
1840
*/
1841
def doOnEach(onNext: T => Unit): Observable[T] = {
1842
- Observable[T](asJavaObservable.asInstanceOf[rx.Observable[T]].doOnEach(
+ Observable[T](asJavaObservable.doOnEach(
1843
onNext
1844
))
1845
}
0 commit comments