From e1bdcd357c72e26447a940045edb7a1c3e8a5c87 Mon Sep 17 00:00:00 2001
From: Agrawal Sujalkumar <sujalagrawal2703@gmail.com>
Date: Sat, 14 Dec 2024 16:31:05 +0530
Subject: [PATCH] savings account summary - non-null parameter is null(Solved)

---
 .../GetSavingsAccountTransactionUseCase.kt    | 40 +++++++++----------
 1 file changed, 20 insertions(+), 20 deletions(-)

diff --git a/core/domain/src/main/java/com/mifos/core/domain/useCases/GetSavingsAccountTransactionUseCase.kt b/core/domain/src/main/java/com/mifos/core/domain/useCases/GetSavingsAccountTransactionUseCase.kt
index 24e4536881..3ab0b6dd45 100644
--- a/core/domain/src/main/java/com/mifos/core/domain/useCases/GetSavingsAccountTransactionUseCase.kt
+++ b/core/domain/src/main/java/com/mifos/core/domain/useCases/GetSavingsAccountTransactionUseCase.kt
@@ -25,28 +25,28 @@ import javax.inject.Inject
  */
 class GetSavingsAccountTransactionUseCase @Inject constructor(private val repository: SavingsAccountTransactionRepository) {
 
-    suspend operator fun invoke(accountId: Int): Flow<Resource<SavingsAccountTransactionRequest>> = callbackFlow {
-        try {
-            trySend(Resource.Loading())
+    suspend operator fun invoke(accountId: Int): Flow<Resource<SavingsAccountTransactionRequest?>> = callbackFlow {
+            try {
+                trySend(Resource.Loading())
 
-            repository.getSavingsAccountTransaction(accountId)
-                .observeOn(AndroidSchedulers.mainThread())
-                .subscribeOn(Schedulers.io())
-                .subscribe(object : Subscriber<SavingsAccountTransactionRequest>() {
-                    override fun onCompleted() {}
+                repository.getSavingsAccountTransaction(accountId)
+                    .observeOn(AndroidSchedulers.mainThread())
+                    .subscribeOn(Schedulers.io())
+                    .subscribe(object : Subscriber<SavingsAccountTransactionRequest?>() {
+                            override fun onCompleted() {}
 
-                    override fun onError(e: Throwable) {
-                        trySend(Resource.Error(e.message.toString()))
-                    }
+                            override fun onError(e: Throwable?) {
+                                trySend(Resource.Error(e?.message.toString()))
+                            }
 
-                    override fun onNext(savingsAccountTransactionRequest: SavingsAccountTransactionRequest) {
-                        trySend(Resource.Success(savingsAccountTransactionRequest))
-                    }
-                })
-
-            awaitClose { channel.close() }
-        } catch (exception: Exception) {
-            send(Resource.Error(exception.message.toString()))
+                            override fun onNext(savingsAccountTransactionRequest: SavingsAccountTransactionRequest?) {
+                                    trySend(Resource.Success(savingsAccountTransactionRequest))
+                            }
+                        },
+                    )
+                awaitClose { channel.close() }
+            } catch (exception: Exception) {
+                send(Resource.Error(exception.message.toString()))
+            }
         }
-    }
 }