Skip to content

Commit bd44425

Browse files
committed
Add nest to RxScala
1 parent ed10ea6 commit bd44425

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

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

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3626,6 +3626,17 @@ trait Observable[+T]
36263626
def lift[R](operator: Subscriber[R] => Subscriber[T]): Observable[R] = {
36273627
toScalaObservable(asJavaObservable.lift(toJavaOperator[T, R](operator)))
36283628
}
3629+
3630+
/**
3631+
* Converts the source `Observable[T]` into an `Observable[Observable[T]]` that emits the source Observable as its single emission.
3632+
*
3633+
* <img width="640" height="350" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/nest.png">
3634+
*
3635+
* @return an Observable that emits a single item: the source Observable
3636+
*/
3637+
def nest: Observable[Observable[T]] = {
3638+
toScalaObservable(asJavaObservable.nest).map(toScalaObservable[T](_))
3639+
}
36293640
}
36303641

36313642
/**

0 commit comments

Comments
 (0)