We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 784f676 commit ba6bf7cCopy full SHA for ba6bf7c
language-adaptors/rxjava-scala/README.md
@@ -5,14 +5,14 @@ This adaptor allows to use RxJava in Scala with anonymous functions, e.g.
5
```scala
6
val o = Observable.interval(200 millis).take(5)
7
o.subscribe(n => println("n = " + n))
8
-Observable(1, 2, 3, 4).reduce(_ + _)
+Observable.items(1, 2, 3, 4).reduce(_ + _)
9
```
10
11
For-comprehensions are also supported:
12
13
14
-val first = Observable(10, 11, 12)
15
-val second = Observable(10, 11, 12)
+val first = Observable.items(10, 11, 12)
+val second = Observable.items(10, 11, 12)
16
val booleans = for ((n1, n2) <- (first zip second)) yield (n1 == n2)
17
18
0 commit comments