Firebase Realtime Genric Callback

ExtensionFun.kt

@ExperimentalCoroutinesApi
inline fun <reified T> DatabaseReference.observeValue(): Flow<NetworkResponse<List<T>>> =
    callbackFlow {
        val listener = object : ValueEventListener {
            override fun onCancelled(error: DatabaseError) {
                trySend(NetworkResponse.Failure(message = error.message))
            }

            override fun onDataChange(snapshot: DataSnapshot) {
                val hostList = arrayListOf<T>()
                snapshot.children.forEach {
                    it.getValue(T::class.java)?.let { it1 -> hostList.add(it1) }
                }
                trySend(
                    NetworkResponse.Success(data = hostList.toList(), message = "Success")
                )
            }
        }
        addValueEventListener(listener)
        awaitClose {
            removeEventListener(listener)
        }
    }.catch {
        emit(NetworkResponse.Failure(it.localizedMessage))
    }