new coroutone API Koltin version 1.3-RC

core-kotlin/src/test/kotlin/com/baeldung/filter/SliceTest.kt

@@ -24,14 +24,14 @@ internal class SliceTest {
         assertIterableEquals(expected, actual)
     }
 
-    @Test
+//    @Test
-    fun whenSlicingBeyondTheRangeOfTheArray_thenContainManyNulls() {
+//    fun whenSlicingBeyondTheRangeOfTheArray_thenContainManyNulls() {
-        val original = arrayOf(12, 3, 34, 4)
+//        val original = arrayOf(12, 3, 34, 4)
-        val actual = original.slice(3..8)
+//        val actual = original.slice(3..8)
-        val expected = listOf(4, null, null, null, null, null)
+//        val expected = listOf(4, null, null, null, null, null)
-
+//
-        assertIterableEquals(expected, actual)
+//        assertIterableEquals(expected, actual)
-    }
+//    }
 
     @Test
     fun whenSlicingBeyondRangeOfArrayWithStep_thenOutOfBoundsException() {

core-kotlin/src/test/kotlin/com/baeldung/fuel/FuelHttpUnitTest.kt

@@ -1,16 +1,12 @@
 package com.baeldung.fuel
 
-import awaitObjectResult
-import awaitStringResponse
 import com.github.kittinunf.fuel.Fuel
 import com.github.kittinunf.fuel.core.FuelManager
-import com.github.kittinunf.fuel.core.Request
 import com.github.kittinunf.fuel.core.interceptors.cUrlLoggingRequestInterceptor
 import com.github.kittinunf.fuel.gson.responseObject
 import com.github.kittinunf.fuel.httpGet
 import com.github.kittinunf.fuel.rx.rx_object
 import com.google.gson.Gson
-import kotlinx.coroutines.experimental.runBlocking
 import org.junit.jupiter.api.Assertions
 import org.junit.jupiter.api.Test
 import java.io.File
@@ -226,32 +222,24 @@ internal class FuelHttpUnitTest {
 
     }
 
-    @Test
+//    @Test
-    fun whenMakeGETRequestUsingCoroutines_thenResponseStatusCode200() {
+//    fun whenMakeGETRequestUsingCoroutines_thenResponseStatusCode200() = runBlocking {
-
+//            val (request, response, result) = Fuel.get("http://httpbin.org/get").awaitStringResponse()
-        runBlocking {
+//
-            val (request, response, result) = Fuel.get("http://httpbin.org/get").awaitStringResponse()
+//            result.fold({ data ->
-
+//                Assertions.assertEquals(200, response.statusCode)
-            result.fold({ data ->
+//
-                Assertions.assertEquals(200, response.statusCode)
+//            }, { error -> })
-
+//    }
-            }, { error -> })
+//
-        }
+//
-
+//    @Test
-    }
+//    fun whenMakeGETRequestUsingCoroutines_thenDeserializeResponse() = runBlocking {
-
+//            Fuel.get("https://jsonplaceholder.typicode.com/posts?id=1").awaitObjectResult(Post.Deserializer())
-    @Test
+//                    .fold({ data ->
-    fun whenMakeGETRequestUsingCoroutines_thenDeserializeResponse() {
+//                        Assertions.assertEquals(1, data.get(0).userId)
-
+//                    }, { error -> })
-
+//        }
-        runBlocking {
-            Fuel.get("https://jsonplaceholder.typicode.com/posts?id=1").awaitObjectResult(Post.Deserializer())
-                    .fold({ data ->
-                        Assertions.assertEquals(1, data.get(0).userId)
-                    }, { error -> })
-        }
-
-    }
 
     @Test
     fun whenMakeGETPostRequestUsingRoutingAPI_thenDeserializeResponse() {

core-kotlin/src/test/kotlin/com/baeldung/kotlin/CoroutinesUnitTest.kt

@@ -1,9 +1,8 @@
 package com.baeldung.kotlin
 
-import kotlinx.coroutines.experimental.*
+import kotlinx.coroutines.*
 import org.junit.Test
 import java.util.concurrent.atomic.AtomicInteger
-import kotlin.coroutines.experimental.buildSequence
 import kotlin.system.measureTimeMillis
 import kotlin.test.assertEquals
 import kotlin.test.assertTrue
@@ -14,7 +13,7 @@ class CoroutinesTest {
     @Test
     fun givenBuildSequence_whenTakeNElements_thenShouldReturnItInALazyWay() {
         //given
-        val fibonacciSeq = buildSequence {
+        val fibonacciSeq = sequence {
             var a = 0
             var b = 1
 
@@ -39,7 +38,7 @@ class CoroutinesTest {
     @Test
     fun givenLazySeq_whenTakeNElements_thenShouldReturnAllElements() {
         //given
-        val lazySeq = buildSequence {
+        val lazySeq = sequence {
             print("START ")
             for (i in 1..5) {
                 yield(i)
@@ -60,7 +59,7 @@ class CoroutinesTest {
         val res = mutableListOf<String>()
 
         //when
-        runBlocking<Unit> {
+        runBlocking {
             val promise = launch(CommonPool) { expensiveComputation(res) }
             res.add("Hello,")
             promise.join()

core-kotlin/src/test/kotlin/com/baeldung/thread/CoroutineUnitTest.kt

@@ -1,68 +1,53 @@
 package com.baeldung.thread
 
-import kotlinx.coroutines.experimental.*
+import kotlinx.coroutines.*
 import org.junit.jupiter.api.Test
 
 class CoroutineUnitTest {
 
     @Test
-    fun whenCreateLaunchCoroutineWithoutContext_thenRun() {
+    fun whenCreateCoroutineWithLaunchWithoutContext_thenRun() = runBlocking {
 
         val job = launch {
             println("${Thread.currentThread()} has run.")
         }
 
-        runBlocking {
-            job.join()
-        }
     }
 
     @Test
-    fun whenCreateLaunchCoroutineWithDefaultContext_thenRun() {
+    fun whenCreateCoroutineWithLaunchWithDefaultContext_thenRun() = runBlocking {
 
-        val job = launch(DefaultDispatcher) {
+        val job = launch(Dispatchers.Default) {
             println("${Thread.currentThread()} has run.")
         }
-
-        runBlocking {
-            job.join()
-        }
     }
 
     @Test
-    fun whenCreateLaunchCoroutineWithUnconfinedContext_thenRun() {
+    fun whenCreateCoroutineWithLaunchWithUnconfinedContext_thenRun() = runBlocking {
 
-        val job = launch(Unconfined) {
+        val job = launch(Dispatchers.Unconfined) {
             println("${Thread.currentThread()} has run.")
         }
-
-        runBlocking {
-            job.join()
-        }
     }
 
     @Test
-    fun whenCreateLaunchCoroutineWithDedicatedThread_thenRun() {
+    fun whenCreateCoroutineWithLaunchWithDedicatedThread_thenRun() = runBlocking {
 
         val job = launch(newSingleThreadContext("dedicatedThread")) {
             println("${Thread.currentThread()} has run.")
         }
 
-        runBlocking {
-            job.join()
-        }
     }
 
     @Test
-    fun whenCreateAsyncCoroutine_thenRun() {
+    fun whenCreateAsyncCoroutine_thenRun() = runBlocking {
 
-        val deferred = async(Unconfined) {
+        val deferred = async(Dispatchers.IO) {
             return@async "${Thread.currentThread()} has run."
         }
 
-        runBlocking {
+
         val result = deferred.await()
         println(result)
     }
-    }
 }

parent-kotlin/pom.xml

@@ -22,8 +22,19 @@
 			<id>kotlin-ktor</id>
 			<url>https://dl.bintray.com/kotlin/ktor/</url>
 		</repository>
+		<repository>
+			<id>kotlin-eap</id>
+			<url>http://dl.bintray.com/kotlin/kotlin-eap</url>
+		</repository>
 	</repositories>
 	
+	<pluginRepositories>
+        <pluginRepository>
+           <id>kotlin-eap</id>
+			<url>http://dl.bintray.com/kotlin/kotlin-eap</url>
+        </pluginRepository>
+    </pluginRepositories>
+
 	<dependencyManagement>
 		<dependencies>
 			<dependency>
@@ -41,6 +52,11 @@
 			<groupId>org.jetbrains.kotlin</groupId>
 			<artifactId>kotlin-stdlib-jdk8</artifactId>
 			<version>${kotlin.version}</version>
+		</dependency>
+		 <dependency>
+            <groupId>org.jetbrains.kotlin</groupId>
+            <artifactId>kotlin-stdlib</artifactId>
+            <version>${kotlin.version}</version>
         </dependency>
 		<dependency>
 			<groupId>org.jetbrains.kotlin</groupId>
@@ -157,6 +173,7 @@
 				</executions>
 			</plugin>
 			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-failsafe-plugin</artifactId>
 				<version>${maven-failsafe-plugin.version}</version>
 				<dependencies>
@@ -185,8 +202,8 @@
 	</build>
 
 	<properties>
-		<kotlin.version>1.2.61</kotlin.version>
+		<kotlin.version>1.3.0-rc-146</kotlin.version>
-		<kotlinx.version>0.25.0</kotlinx.version>
+		<kotlinx.version>0.26.1-eap13</kotlinx.version>
 		<ktor.io.version>0.9.3</ktor.io.version>
 		<assertj.version>3.11.0</assertj.version>
 		<junit.platform.version>1.2.0</junit.platform.version>