diff options
author | Allan Wang <me@allanwang.ca> | 2018-12-27 14:34:29 -0500 |
---|---|---|
committer | Allan Wang <me@allanwang.ca> | 2018-12-27 14:34:29 -0500 |
commit | f9e3a324e47a81a30aade003cf6f829d03c81414 (patch) | |
tree | 655a7fc8894170716986a0cab1c784822d750f6f /app/src/test/kotlin | |
parent | e6dcbd7b32dc49b11184b6beca598819c3f071fd (diff) | |
download | frost-f9e3a324e47a81a30aade003cf6f829d03c81414.tar.gz frost-f9e3a324e47a81a30aade003cf6f829d03c81414.tar.bz2 frost-f9e3a324e47a81a30aade003cf6f829d03c81414.zip |
Convert remaining view observables
Diffstat (limited to 'app/src/test/kotlin')
-rw-r--r-- | app/src/test/kotlin/com/pitchedapps/frost/MiscTest.kt | 35 |
1 files changed, 0 insertions, 35 deletions
diff --git a/app/src/test/kotlin/com/pitchedapps/frost/MiscTest.kt b/app/src/test/kotlin/com/pitchedapps/frost/MiscTest.kt index 2676e37d..20610b2a 100644 --- a/app/src/test/kotlin/com/pitchedapps/frost/MiscTest.kt +++ b/app/src/test/kotlin/com/pitchedapps/frost/MiscTest.kt @@ -17,15 +17,7 @@ package com.pitchedapps.frost import com.pitchedapps.frost.facebook.requests.zip -import kotlinx.coroutines.Dispatchers -import kotlinx.coroutines.ExperimentalCoroutinesApi -import kotlinx.coroutines.asCoroutineDispatcher -import kotlinx.coroutines.channels.BroadcastChannel -import kotlinx.coroutines.delay -import kotlinx.coroutines.launch -import kotlinx.coroutines.runBlocking import org.junit.Test -import java.util.concurrent.Executors import kotlin.test.assertTrue /** @@ -53,31 +45,4 @@ class MiscTest { "zip did not seem to work on different threads" ) } - -@Test -@UseExperimental(ExperimentalCoroutinesApi::class) -fun channel() { - val c = BroadcastChannel<Int>(100) - runBlocking { - launch(Dispatchers.IO) { - println("1 start ${Thread.currentThread()}") - for (i in c.openSubscription()) { - println("1 $i") - } - println("1 end ${Thread.currentThread()}") - } - launch(Dispatchers.IO) { - println("2 start ${Thread.currentThread()}") - for (i in c.openSubscription()) { - println("2 $i") - } - println("2 end ${Thread.currentThread()}") - } - c.send(1) - c.send(2) - c.send(3) - delay(1000) - c.close() - } -} } |