Fixed rx2.ObservableMultiTest.testSendAndCrash

elizarov · elizarov · commit 35af7c880861 · 2017-03-17T18:08:29.000+03:00
diff --git a/reactive/kotlinx-coroutines-rx2/src/test/kotlin/kotlinx/coroutines/experimental/rx2/ObservableMultiTest.kt b/reactive/kotlinx-coroutines-rx2/src/test/kotlin/kotlinx/coroutines/experimental/rx2/ObservableMultiTest.kt
@@ -90,7 +90,7 @@ class ObservableMultiTest : TestBase() {
         val single = rxSingle(CommonPool) {
             var result = ""
             try {
-                observable.forEach { result += it }
+                observable.consumeEach { result += it }
             } catch(e: IOException) {
                 result += e.message
             }

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ class ObservableMultiTest : TestBase() {`
`90`	`90`	`val single = rxSingle(CommonPool) {`
`91`	`91`	`var result = ""`
`92`	`92`	`try {`
`93`		`- observable.forEach { result += it }`
	`93`	`+ observable.consumeEach { result += it }`
`94`	`94`	`} catch(e: IOException) {`
`95`	`95`	`result += e.message`
`96`	`96`	`}`