File tree Expand file tree Collapse file tree 4 files changed +5
-88
lines changed
main/kotlin/rx/lang/kotlin
test/kotlin/rx/lang/kotlin Expand file tree Collapse file tree 4 files changed +5
-88
lines changed Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -34,12 +34,9 @@ public class BasicKotlinTests : KotlinTests() {
34
34
35
35
@Test
36
36
public fun testCreate () {
37
-
38
- Observable .create(object : OnSubscribe <String > {
39
- override fun call (subscriber : Subscriber <in String >) {
40
- subscriber.onNext(" Hello" )
41
- subscriber.onCompleted()
42
- }
37
+ Observable .create(OnSubscribe < kotlin.String > { subscriber ->
38
+ subscriber.onNext(" Hello" )
39
+ subscriber.onCompleted()
43
40
}).subscribe { result ->
44
41
a.received(result)
45
42
}
Original file line number Diff line number Diff line change @@ -116,7 +116,7 @@ public class ExtensionTests : KotlinTests() {
116
116
@Test
117
117
public fun testScriptWithMerge () {
118
118
val factory = TestFactory ()
119
- (factory.observable mergeWith factory.observable).subscribe((received()))
119
+ (factory.observable. mergeWith( factory.observable) ).subscribe((received()))
120
120
verify(a, times(1 )).received(" hello_1" )
121
121
verify(a, times(1 )).received(" hello_2" )
122
122
}
Original file line number Diff line number Diff line change @@ -58,7 +58,7 @@ public class ObservablesTest {
58
58
assertEquals((1 .. 10 ).toList(), (1 .. 10 ).toObservable().toList().toBlocking().first())
59
59
}
60
60
61
- @test fun intProgressionDownto () {
61
+ @test fun intProgressionDownTo () {
62
62
assertEquals((1 downTo 10 ).toList(), (1 downTo 10 ).toObservable().toList().toBlocking().first())
63
63
}
64
64
You can’t perform that action at this time.
0 commit comments