skip

Author: hangga

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

@@ -32,9 +32,7 @@ class SingleRxJavaToCoroutineDeferredUnitTest {
 
     private suspend fun Deferred<*>.assertOver500AndSorted() {
         assertThat(this.await() as List<*>).containsExactly(
-            Product(4, "Lenovo", 550.0),
-            Product(2, "Oppo", 800.0),
-            Product(1, "Samsung", 1200.0)
+            Product(4, "Lenovo", 550.0), Product(2, "Oppo", 800.0), Product(1, "Samsung", 1200.0)
         )
     }
 
@@ -46,13 +44,20 @@ class SingleRxJavaToCoroutineDeferredUnitTest {
     }
 
     @Test
-    fun `using subscribe and CompletableDeferred`() = runBlocking {
+    fun `using subscribe and CompletableDeferred`(): Unit = runBlocking {
+//        val deferred = CompletableDeferred<List<Product>>()
+//        getFilteredProducts().subscribe({ products ->
+//            deferred.complete(products)
+//        }, { error ->
+//            deferred.completeExceptionally(error)
+//        })
+//        deferred.assertOver500AndSorted()
         val deferred = CompletableDeferred<List<Product>>()
-        getFilteredProducts().subscribe({ products ->
-            deferred.complete(products)
-        }, { error ->
-            deferred.completeExceptionally(error)
-        })
+//        async {
+            getFilteredProducts().subscribeOn(Schedulers.io()).observeOn(Schedulers.io()).subscribe { products ->
+                deferred.complete(products)
+            }
+//        }
         deferred.assertOver500AndSorted()
     }