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

hangga · theangrydev · web-flow · commit 64bc8d7b8f94 · 2024-05-15T16:20:56.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
@@ -65,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()

Original file line number	Diff line number	Diff line change
`@@ -65,11 +65,7 @@ class SingleRxJavaToCoroutineDeferredUnitTest {`
`65`	`65`	fun `using suspendCancellableCoroutine`(): Unit = runBlocking {
`66`	`66`	`val deferred = async {`
`67`	`67`	`suspendCancellableCoroutine { continuation ->`
`68`		`- getFilteredProducts().subscribe({ result ->`
`69`		`- continuation.resume(result)`
`70`		`- }, { error ->`
`71`		`- continuation.resumeWithException(error)`
`72`		`- })`
	`68`	`+ getFilteredProducts().subscribe(continuation::resume, continuation::resumeWithException)`
`73`	`69`	`}`
`74`	`70`	`}`
`75`	`71`	`deferred.assertOver500AndSorted()`