commit 00560e8b0add1628bd0a32202b6f3cc301b35af3
author Roman Elizarov <elizarov@gmail.com> Mon Mar 05 17:58:59 2018 +0300
committer Roman Elizarov <elizarov@gmail.com> Mon Mar 05 18:00:50 2018 +0300
tree baf151b458d44ca147afb4de6c2e4956df7c9d64
parent 727331c2aee0e47c5392e2b816b2efc8d1c13b6c

rx-example: Added application plugin & fixed to use runBlocking

reactive/kotlinx-coroutines-rx-example/build.gradle

diff --git a/reactive/kotlinx-coroutines-rx-example/build.gradle b/reactive/kotlinx-coroutines-rx-example/build.gradle
index cebc2ef..aaa1c27 100644
--- a/reactive/kotlinx-coroutines-rx-example/build.gradle
+++ b/reactive/kotlinx-coroutines-rx-example/build.gradle
@@ -1,3 +1,8 @@
+
+apply plugin: 'application'
+
+mainClassName = 'MainKt'
+
 dependencies {
     ext.retrofit_version = '2.3.0'
     compile project(':kotlinx-coroutines-rx2')

reactive/kotlinx-coroutines-rx-example/src/main/kotlin/main.kt

diff --git a/reactive/kotlinx-coroutines-rx-example/src/main/kotlin/main.kt b/reactive/kotlinx-coroutines-rx-example/src/main/kotlin/main.kt
index 391188d..e884948 100644
--- a/reactive/kotlinx-coroutines-rx-example/src/main/kotlin/main.kt
+++ b/reactive/kotlinx-coroutines-rx-example/src/main/kotlin/main.kt
@@ -15,8 +15,7 @@
  */
 
 import io.reactivex.Single
-import kotlinx.coroutines.experimental.CommonPool
-import kotlinx.coroutines.experimental.launch
+import kotlinx.coroutines.experimental.*
 import kotlinx.coroutines.experimental.rx2.await
 import retrofit2.Retrofit
 import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
@@ -38,7 +37,9 @@
 data class Contributor(val login: String, val contributions: Int)
 data class Repo(val name: String)
 
-fun main(args: Array<String>) {
+fun main(args: Array<String>) = runBlocking {
+    println("Making GitHub API request")
+    
     val retrofit = Retrofit.Builder().apply {
         baseUrl("https://api.github.com")
         addConverterFactory(GsonConverterFactory.create())
@@ -47,19 +48,17 @@
 
     val github = retrofit.create(GitHub::class.java)
 
-    launch(CommonPool) {
-        val contributors =
-                github.contributors("JetBrains", "Kotlin")
-                      .await().take(10)
+    val contributors =
+            github.contributors("JetBrains", "Kotlin")
+                  .await().take(10)
 
-        for ((name, contributions) in contributors) {
-            println("$name has $contributions contributions, other repos: ")
+    for ((name, contributions) in contributors) {
+        println("$name has $contributions contributions, other repos: ")
 
-            val otherRepos =
-                    github.listRepos(name).await()
-                          .map(Repo::name).joinToString(", ")
+        val otherRepos =
+                github.listRepos(name).await()
+                      .map(Repo::name).joinToString(", ")
 
-            println(otherRepos)
-        }
+        println(otherRepos)
     }
 }