Allow null return values (for example when the decoding fails and the…

… error handler returns null)
sipgate · Mar 11, 2024 · 7040a89 · 7040a89
1 parent 18bb2e4
commit 7040a89
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/realtimedb/src/main/kotlin/de/sipgate/federmappe/realtimedb/DatabaseReferenceExt.kt b/realtimedb/src/main/kotlin/de/sipgate/federmappe/realtimedb/DatabaseReferenceExt.kt
@@ -17,7 +17,7 @@ import kotlinx.serialization.serializer
 inline fun <reified T: Any> DatabaseReference.toObject(
     serializer: KSerializer<T> = serializer<T>(),
     crossinline errorHandler: (Throwable) -> T? = { throw it }
-): Flow<T> {
+): Flow<T?> {
     return callbackFlow {
         val valueEventListener = object : ValueEventListener {
             override fun onCancelled(error: DatabaseError) {
@@ -32,9 +32,7 @@ inline fun <reified T: Any> DatabaseReference.toObject(
                         errorHandler(ex)
                     }
 
-                if (decodedAppData != null) {
-                    trySend(decodedAppData)
-                }
+                trySend(decodedAppData)
             }
         }