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

hangga · theangrydev · web-flow · commit 227b62f4627c · 2024-05-15T16:20:34.000+07:00
Co-authored-by: Liam Williams &lt;liam.williams@zoho.com&gt;
diff --git a/core-kotlin-modules/core-kotlin-concurrency-3/src/test/java/com/baeldung/singlerxjavatocoroutinedeferred/SingleRxJavaToCoroutineDeferredUnitTest.kt b/core-kotlin-modules/core-kotlin-concurrency-3/src/test/java/com/baeldung/singlerxjavatocoroutinedeferred/SingleRxJavaToCoroutineDeferredUnitTest.kt
@@ -56,9 +56,7 @@ class SingleRxJavaToCoroutineDeferredUnitTest {
     fun `using suspendCoroutines`(): Unit = runBlocking {
         val deferred = async {
             suspendCoroutine { continuation ->
-                getFilteredProducts().subscribe { result ->
-                    continuation.resume(result)
-                }
+                getFilteredProducts().subscribe(continuation::resume)
             }
         }
         deferred.assertOver500AndSorted()

Original file line number	Diff line number	Diff line change
`@@ -56,9 +56,7 @@ class SingleRxJavaToCoroutineDeferredUnitTest {`
`56`	`56`	fun `using suspendCoroutines`(): Unit = runBlocking {
`57`	`57`	`val deferred = async {`
`58`	`58`	`suspendCoroutine { continuation ->`
`59`		`- getFilteredProducts().subscribe { result ->`
`60`		`- continuation.resume(result)`
`61`		`- }`
	`59`	`+ getFilteredProducts().subscribe(continuation::resume)`
`62`	`60`	`}`
`63`	`61`	`}`
`64`	`62`	`deferred.assertOver500AndSorted()`