resolve pom xml

Author: hangga

core-kotlin-modules/core-kotlin-concurrency-3/pom.xml

@@ -15,27 +15,30 @@
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <rxkotlin.version>2.3.0</rxkotlin.version>
+        <rxkotlin.version>3.0.1</rxkotlin.version>
+        <rxcoroutines.version>1.8.1</rxcoroutines.version>
+        <junit.version>3.8.1</junit.version>
     </properties>
 
     <dependencies>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
-            <version>3.8.1</version>
-            <scope>test</scope>
+            <version>${junit.version}</version>
         </dependency>
 
         <dependency>
             <groupId>io.reactivex.rxjava3</groupId>
             <artifactId>rxkotlin</artifactId>
-            <version>3.0.1</version>
+            <version>${rxkotlin.version}</version>
         </dependency>
 
         <dependency>
             <groupId>org.jetbrains.kotlinx</groupId>
             <artifactId>kotlinx-coroutines-rx3</artifactId>
-            <version>1.8.1</version>
+            <version>${rxcoroutines.version}</version>
         </dependency>
     </dependencies>
+
+
 </project>

core-kotlin-modules/core-kotlin-concurrency-3/src/test/java/com/baeldung/singlerxjavatocoroutinedeferred/SingleRxJavaToCoroutineDeferredUnitTest.kt

@@ -40,29 +40,22 @@ class SingleRxJavaToCoroutineDeferredUnitTest {
 
     @Test
     fun `using async and blockingGet`() = runBlocking {
-        val deferred =
-            async { getFilteredProducts().blockingGet() } // potentially blocking main thread while not careful
-        deferred.assertOver500AndSorted() // assertion test
+        val deferred = async { getFilteredProducts().blockingGet() }
+        deferred.assertOver500AndSorted()
     }
 
     @Test
     fun `using subscribe and CompletableDeferred`() = runBlocking {
         val deferred = CompletableDeferred<List<Product>>()
-        getFilteredProducts().subscribe({ products ->
-            deferred.complete(products)
-        }, { error ->
-            deferred.completeExceptionally(error)
-        })
+        getFilteredProducts().subscribe(deferred::complete, deferred::completeExceptionally)
         deferred.assertOver500AndSorted()
     }
 
     @Test
     fun `using suspendCoroutines`(): Unit = runBlocking {
         val deferred = async {
             suspendCoroutine { continuation ->
-                getFilteredProducts().subscribe { result ->
-                    continuation.resume(result)
-                }
+                getFilteredProducts().subscribe(continuation::resume, continuation::resumeWithException)
             }
         }
         deferred.assertOver500AndSorted()
@@ -72,11 +65,7 @@ class SingleRxJavaToCoroutineDeferredUnitTest {
     fun `using suspendCancellableCoroutine`(): Unit = runBlocking {
         val deferred = async {
             suspendCancellableCoroutine { continuation ->
-                getFilteredProducts().subscribe({ result ->
-                    continuation.resume(result)
-                }, { error ->
-                    continuation.resumeWithException(error)
-                })
+                getFilteredProducts().subscribe(continuation::resume, continuation::resumeWithException)
             }
         }
         deferred.assertOver500AndSorted()