Skip to content

Commit 205a16b

Browse files
committed
Adds scala adapters for doOnEach operator
1 parent 04edc95 commit 205a16b

File tree

1 file changed

+22
-0
lines changed

1 file changed

+22
-0
lines changed

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

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)