aboutsummaryrefslogtreecommitdiff
path: root/app/src/test/kotlin/com/pitchedapps
diff options
context:
space:
mode:
authorAllan Wang <me@allanwang.ca>2018-12-27 14:34:29 -0500
committerAllan Wang <me@allanwang.ca>2018-12-27 14:34:29 -0500
commitf9e3a324e47a81a30aade003cf6f829d03c81414 (patch)
tree655a7fc8894170716986a0cab1c784822d750f6f /app/src/test/kotlin/com/pitchedapps
parente6dcbd7b32dc49b11184b6beca598819c3f071fd (diff)
downloadfrost-f9e3a324e47a81a30aade003cf6f829d03c81414.tar.gz
frost-f9e3a324e47a81a30aade003cf6f829d03c81414.tar.bz2
frost-f9e3a324e47a81a30aade003cf6f829d03c81414.zip
Convert remaining view observables
Diffstat (limited to 'app/src/test/kotlin/com/pitchedapps')
-rw-r--r--app/src/test/kotlin/com/pitchedapps/frost/MiscTest.kt35
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()
- }
-}
}