Skip to content

Commit c5605bc

Browse files
committed
Add subscribeExample to explain subscribe and foreach are same
1 parent a6f22b2 commit c5605bc

File tree

1 file changed

+23
-0
lines changed
  • language-adaptors/rxjava-scala/src/examples/scala/rx/lang/scala/examples

1 file changed

+23
-0
lines changed

language-adaptors/rxjava-scala/src/examples/scala/rx/lang/scala/examples/RxScalaDemo.scala

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,29 @@ import rx.lang.scala.schedulers._
4848
@Ignore // Since this doesn't do automatic testing, don't increase build time unnecessarily
4949
class RxScalaDemo extends JUnitSuite {
5050

51+
@Test def subscribeExample() {
52+
val o = Observable.items(1, 2, 3)
53+
54+
// Generally, we have two methods, `subscribe` and `foreach`, to listen to the messages from an Observable.
55+
// `foreach` is just an alias to `subscribe`.
56+
o.subscribe(
57+
n => println(n),
58+
e => e.printStackTrace(),
59+
() => println("done")
60+
)
61+
62+
o.foreach(
63+
n => println(n),
64+
e => e.printStackTrace(),
65+
() => println("done")
66+
)
67+
68+
// For-comprehension is also an alternative, if you are only interested in `onNext`
69+
for (i <- o) {
70+
println(i)
71+
}
72+
}
73+
5174
@Test def intervalExample() {
5275
val o = Observable.interval(200 millis).take(5)
5376
o.subscribe(n => println("n = " + n))

0 commit comments

Comments
 (0)