issue450.kt

import kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.rx1.awaitFirst
import kotlinx.coroutines.experimental.rx1.rxObservable
import java.util.concurrent.TimeUnit

fun fetchFromNetwork() = rxObservable {
    delay(1, TimeUnit.HOURS)
    send("Result from network")
}

fun getResult() = rxObservable {
    val result = fetchFromNetwork().awaitFirst()
    send("network" in result)
}

fun main(args: Array<String>) {
    val subscription = getResult().subscribe()
    subscription.unsubscribe()
}