File tree Expand file tree Collapse file tree 1 file changed +22
-0
lines changed
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala Expand file tree Collapse file tree 1 file changed +22
-0
lines changed Original file line number Diff line number Diff line change @@ -1807,6 +1807,28 @@ class Observable[+T] private[scala] (val asJava: rx.Observable[_ <: T])
18071807 def withFilter (p : T => Boolean ): WithFilter [T ] = {
18081808 new WithFilter [T ](p, asJava)
18091809 }
1810+
1811+
1812+ def doOnEach (observer : Observer [T ]): Observable [T ] = {
1813+ Observable [T ](asJava.doOnEach(observer))
1814+ }
1815+
1816+ def doOnEach (onNext : T => Unit ): Observable [T ] = {
1817+ Observable [T ](asJava.doOnEach(onNext))
1818+ }
1819+
1820+ def doOnEach (onNext : T => Unit , onComplete : () => Unit ): Observable [T ] = {
1821+ Observable [T ](asJava.doOnEach(onNext, onComplete))
1822+ }
1823+
1824+ def doOnEach (onNext : T => Unit , onError : Throwable => Unit ): Observable [T ] = {
1825+ Observable [T ](asJava.doOnEach(onNext, onError))
1826+ }
1827+
1828+ def doOnEach (onNext : T => Unit , onError : Throwable => Unit , onComplete : () => Unit ): Observable [T ] = {
1829+ Observable [T ](asJava.doOnEach(onNext, onError, onComplete))
1830+ }
1831+
18101832
18111833}
18121834
You can’t perform that action at this time.
0 commit comments