commit dc29b071d4784e3739f89223ced2333ecd5408ad
author Roman Elizarov <elizarov@gmail.com> Tue Sep 11 18:42:03 2018 +0300
committer Vsevolod Tolstopyatov <qwwdfsad@gmail.com> Tue Sep 11 19:59:13 2018 +0300
tree 8ff1fc878e076deac7124ea8a4f0fef707888fc1
parent bbaf99d5b31c9d03dbf2f4567b22918318a689ca

Dispatchers are renamed and grouped in the Dispatchers object

* Dispatchers.Default — a default dispatcher for background asynchronous tasks
  (currently backed by FJP commonPool, a new dispatcher in the future).
* Dispatchers.IO — a dispatcher for blocking background operations (#79).
* Dispatchers.Main — a dispatcher for Android Main Thread (#533).
* Dispatchers.Swing — a dispatcher for Swing Event Dispatch Thread.
* Dispatchers.JavaFx — a dispatcher for JavaFx Application Thread.
* Old dispatchers are deprecated, CommonPool is deprecated, too.
* awaitPulse() in JavaFx and awaitFrame() in Android are top-level funs.
* Introduced HandlerDispatcher, SwingDispatcher, and JavaFxDispatcher types
  in the corresponding UI modules for type-safety and future extensions

Fixes #41
Fixes #533

reactive/kotlinx-coroutines-rx2/test/ConvertTest.kt

diff --git a/reactive/kotlinx-coroutines-rx2/test/ConvertTest.kt b/reactive/kotlinx-coroutines-rx2/test/ConvertTest.kt
index 5284725..aedda13 100644
--- a/reactive/kotlinx-coroutines-rx2/test/ConvertTest.kt
+++ b/reactive/kotlinx-coroutines-rx2/test/ConvertTest.kt
@@ -49,11 +49,11 @@
             delay(50)
             "OK"
         }
-        val maybe1 = d.asMaybe(Unconfined)
+        val maybe1 = d.asMaybe(Dispatchers.Unconfined)
         checkMaybeValue(maybe1) {
             assertEquals("OK", it)
         }
-        val maybe2 = d.asMaybe(Unconfined)
+        val maybe2 = d.asMaybe(Dispatchers.Unconfined)
         checkMaybeValue(maybe2) {
             assertEquals("OK", it)
         }
@@ -65,9 +65,9 @@
             delay(50)
             null
         }
-        val maybe1 = d.asMaybe(Unconfined)
+        val maybe1 = d.asMaybe(Dispatchers.Unconfined)
         checkMaybeValue(maybe1, ::assertNull)
-        val maybe2 = d.asMaybe(Unconfined)
+        val maybe2 = d.asMaybe(Dispatchers.Unconfined)
         checkMaybeValue(maybe2, ::assertNull)
     }
 
@@ -77,11 +77,11 @@
             delay(50)
             throw TestException("OK")
         }
-        val maybe1 = d.asMaybe(Unconfined)
+        val maybe1 = d.asMaybe(Dispatchers.Unconfined)
         checkErroneous(maybe1) {
             check(it is TestException && it.message == "OK") { "$it" }
         }
-        val maybe2 = d.asMaybe(Unconfined)
+        val maybe2 = d.asMaybe(Dispatchers.Unconfined)
         checkErroneous(maybe2) {
             check(it is TestException && it.message == "OK") { "$it" }
         }
@@ -93,11 +93,11 @@
             delay(50)
             "OK"
         }
-        val single1 = d.asSingle(Unconfined)
+        val single1 = d.asSingle(Dispatchers.Unconfined)
         checkSingleValue(single1) {
             assertEquals("OK", it)
         }
-        val single2 = d.asSingle(Unconfined)
+        val single2 = d.asSingle(Dispatchers.Unconfined)
         checkSingleValue(single2) {
             assertEquals("OK", it)
         }
@@ -109,11 +109,11 @@
             delay(50)
             throw TestException("OK")
         }
-        val single1 = d.asSingle(Unconfined)
+        val single1 = d.asSingle(Dispatchers.Unconfined)
         checkErroneous(single1) {
             check(it is TestException && it.message == "OK") { "$it" }
         }
-        val single2 = d.asSingle(Unconfined)
+        val single2 = d.asSingle(Dispatchers.Unconfined)
         checkErroneous(single2) {
             check(it is TestException && it.message == "OK") { "$it" }
         }
@@ -127,7 +127,7 @@
             delay(50)
             send("K")
         }
-        val observable = c.asObservable(Unconfined)
+        val observable = c.asObservable(Dispatchers.Unconfined)
         checkSingleValue(observable.reduce { t1, t2 -> t1 + t2 }.toSingle()) {
             assertEquals("OK", it)
         }
@@ -141,8 +141,8 @@
             delay(50)
             throw TestException("K")
         }
-        val observable = c.asObservable(Unconfined)
-        val single = GlobalScope.rxSingle(Unconfined) {
+        val observable = c.asObservable(Dispatchers.Unconfined)
+        val single = GlobalScope.rxSingle(Dispatchers.Unconfined) {
             var result = ""
             try {
                 observable.consumeEach { result += it }