adapt examples for use with ReceiveChannel

Author: deva666

reactive/kotlinx-coroutines-reactive/src/test/kotlin/kotlinx/coroutines/experimental/reactive/IntegrationTest.kt

@@ -106,7 +106,7 @@ class IntegrationTest(
         checkNumbers(n, pub)
         val channel = pub.openSubscription()
         checkNumbers(n, channel.asPublisher(ctx(coroutineContext)))
-        channel.close()
+        channel.cancel()
     }
 
     private suspend fun checkNumbers(n: Int, pub: Publisher<Int>) {

reactive/kotlinx-coroutines-rx1/src/test/kotlin/kotlinx/coroutines/experimental/rx1/IntegrationTest.kt

@@ -128,7 +128,7 @@ class IntegrationTest(
         checkNumbers(n, observable)
         val channel = observable.openSubscription()
         checkNumbers(n, channel.asObservable(ctx(coroutineContext)))
-        channel.close()
+        channel.cancel()
     }
 
     private suspend fun checkNumbers(n: Int, observable: Observable<Int>) {

reactive/kotlinx-coroutines-rx2/src/test/kotlin/guide/example-reactive-basic-03.kt

@@ -26,11 +26,10 @@ fun main(args: Array<String>) = runBlocking<Unit> {
         .doOnSubscribe { println("OnSubscribe") } // provide some insight
         .doFinally { println("Finally") }         // ... into what's going on
     var cnt = 0 
-    source.openSubscription().use { channel -> // open channel to the source
-        for (x in channel) { // iterate over the channel to receive elements from it
-            println(x)
-            if (++cnt >= 3) break // break when 3 elements are printed
-        }
-        // `use` will close the channel when this block of code is complete
+    val channel = source.openSubscription() // open channel to the source
+    for (x in channel) { // iterate over the channel to receive elements from it
+        println(x)
+        if (++cnt >= 3) break // break when 3 elements are printed
     }
+    channel.cancel()    // `cancel` closes the channel
 }

reactive/kotlinx-coroutines-rx2/src/test/kotlin/guide/example-reactive-operators-03.kt

@@ -24,14 +24,14 @@ import kotlin.coroutines.experimental.CoroutineContext
 import kotlinx.coroutines.experimental.selects.whileSelect
 
 fun <T, U> Publisher<T>.takeUntil(context: CoroutineContext, other: Publisher<U>) = publish<T>(context) {
-    this@takeUntil.openSubscription().use { thisChannel -> // explicitly open channel to Publisher<T>
-        other.openSubscription().use { otherChannel ->     // explicitly open channel to Publisher<U>
-            whileSelect {
-                otherChannel.onReceive { false }          // bail out on any received element from `other`
-                thisChannel.onReceive { send(it); true }  // resend element from this channel and continue
-            }
-        }
+    val thisChannel = this@takeUntil.openSubscription() // explicitly open channel to Publisher<T>
+    val otherChannel = other.openSubscription() // explicitly open channel to Publisher<U>
+    whileSelect {
+        otherChannel.onReceive { false }          // bail out on any received element from `other`
+        thisChannel.onReceive { send(it); true }  // resend element from this channel and continue
     }
+    thisChannel.cancel()
+    otherChannel.cancel()
 }
 
 fun rangeWithInterval(context: CoroutineContext, time: Long, start: Int, count: Int) = publish<Int>(context) {

reactive/kotlinx-coroutines-rx2/src/test/kotlin/kotlinx/coroutines/experimental/rx2/IntegrationTest.kt

@@ -108,7 +108,7 @@ class IntegrationTest(
         checkNumbers(n, observable)
         val channel = observable.openSubscription()
         checkNumbers(n, channel.asObservable(ctx(coroutineContext)))
-        channel.close()
+        channel.cancel()
     }
 
     private suspend fun checkNumbers(n: Int, observable: Observable<Int>) {