@@ -34,7 +34,7 @@ import org.scalatest.{FlatSpec, Matchers}
34
34
class ScalaObservableSpec extends FlatSpec with Matchers {
35
35
36
36
" ScalaObservable" should " allow for inline subscription" in {
37
- var results = ArrayBuffer [Int ]()
37
+ val results = ArrayBuffer [Int ]()
38
38
observable().subscribe((res : Int ) => results += res)
39
39
results should equal(1 to 100 )
40
40
@@ -48,14 +48,14 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
48
48
}
49
49
50
50
it should " have a foreach method" in {
51
- var results = ArrayBuffer [Int ]()
51
+ val results = ArrayBuffer [Int ]()
52
52
observable().foreach((res : Int ) => results += res)
53
53
results should equal(1 to 100 )
54
54
}
55
55
56
56
it should " have a transform method" in {
57
57
var completed = false
58
- var results = ArrayBuffer [String ]()
58
+ val results = ArrayBuffer [String ]()
59
59
observable[Int ]()
60
60
.transform((res : Int ) => res.toString, (ex : Throwable ) => ex)
61
61
.subscribe((s : String ) => results += s, (t : Throwable ) => (), () => completed = true )
@@ -74,7 +74,7 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
74
74
}
75
75
76
76
it should " have a map method" in {
77
- var results = ArrayBuffer [String ]()
77
+ val results = ArrayBuffer [String ]()
78
78
var completed = false
79
79
observable[Int ]()
80
80
.map((res : Int ) => res.toString)
@@ -87,7 +87,7 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
87
87
def myObservable (fail : Boolean = false ): Observable [String ] =
88
88
observable[Int ](fail = fail).flatMap((res : Int ) => observable(List (res.toString)))
89
89
90
- var results = ArrayBuffer [String ]()
90
+ val results = ArrayBuffer [String ]()
91
91
myObservable().subscribe((s : String ) => results += s)
92
92
results should equal((1 to 100 ).map(_.toString))
93
93
@@ -105,7 +105,7 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
105
105
it should " have a filter method" in {
106
106
def myObservable (fail : Boolean = false ): Observable [Int ] = observable[Int ](fail = fail).filter((i : Int ) => i % 2 != 0 )
107
107
108
- var results = ArrayBuffer [Int ]()
108
+ val results = ArrayBuffer [Int ]()
109
109
myObservable().subscribe((i : Int ) => results += i)
110
110
results should equal((1 to 100 ).filter(i => i % 2 != 0 ))
111
111
@@ -121,7 +121,7 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
121
121
it should " have a withFilter method" in {
122
122
def myObservable (fail : Boolean = false ): Observable [Int ] = observable[Int ](fail = fail).withFilter((i : Int ) => i % 2 != 0 )
123
123
124
- var results = ArrayBuffer [Int ]()
124
+ val results = ArrayBuffer [Int ]()
125
125
myObservable().subscribe((i : Int ) => results += i)
126
126
results should equal((1 to 100 ).filter(i => i % 2 != 0 ))
127
127
@@ -139,7 +139,7 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
139
139
observable[Int ](fail = fail).collect()
140
140
}
141
141
142
- var results = ArrayBuffer [Int ]()
142
+ val results = ArrayBuffer [Int ]()
143
143
myObservable().subscribe((i : Seq [Int ]) => results ++= i)
144
144
results should equal(1 to 100 )
145
145
@@ -253,7 +253,7 @@ class ScalaObservableSpec extends FlatSpec with Matchers {
253
253
}
254
254
255
255
it should " have a zip method" in {
256
- var results = ArrayBuffer [(Int , String )]()
256
+ val results = ArrayBuffer [(Int , String )]()
257
257
observable[Int ]().zip(observable().map(i => i.toString)).subscribe((res : (Int , String )) => results += res)
258
258
results should equal((1 to 100 ).zip((1 to 100 ).map(_.toString)))
259
259
}
0 commit comments