Estoy tratando de ejecutar una transacción de Firebase con una función suspendida en Kotlin y no veo documentación al respecto.
Estoy usando
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-play-services:1.5.2'para rutinas con firebase (p. ej.: setValue(*).await() ) pero parece que no hay una función de espera para runTransaction(*)
override suspend fun modifyProductStock( product: ProductModel, valueToModify: Long, replace: Boolean ) { CoroutineScope(Dispatchers.Main).launch { val restaurantId = authRepository.restaurantId.value ?: throw Exception("No restaurant!") val productId = product.id ?: throw Exception("No Product ID!") val reference = FirebaseDatabase.getInstance().getReference("database/$restaurantId").child("products") if (replace) { reference.child(productId).child("stock").setValue(valueToModify).await() } else { reference.child(productId).child("stock") .runTransaction(object : Transaction.Handler { override fun doTransaction(p0: MutableData): Transaction.Result { //any operation return Transaction.success(p0) } override fun onComplete(p0: DatabaseError?, p1: Boolean, p2: DataSnapshot?) { } }) } } }Podrías envolverlo en suspendCoroutine :
val result: DataSnapshot? = suspendCoroutine { c -> reference.child(productId).child("stock") .runTransaction(object : Transaction.Handler { override fun doTransaction(p0: MutableData): Transaction.Result { //any operation return Transaction.success(p0) } override fun onComplete(error: DatabaseError?, p1: Boolean, snapshot: DataSnapshot?) { c.resume(snapshot) } }) }Obtiene la instancia de continuación actual dentro de las funciones de suspensión y suspende la rutina que se está ejecutando actualmente.
En esta función, tanto Continuation.resume como Continuation.resumeWithException se pueden usar de forma síncrona en el mismo marco de pila donde se ejecuta la función de suspensión o de forma asíncrona más tarde en el mismo subproceso o desde un subproceso de ejecución diferente.
Dado que el ejemplo de Kotlin en la documentación de Firebase sobre transacciones usa el mismo estilo de devolución de llamada que tiene, parece que no hay soporte específico para co-rutinas allí.
Puede valer la pena publicar un problema en el repositorio SDK de Android para agregarlo o saber por qué no se agregó.