QueryAsFlow.kt

fun Query.asFlow(): Flow<QuerySnapshot> {
    return callbackFlow {
        val callback = addSnapshotListener { querySnapshot, ex ->
            if (ex != null) {
                close(ex)
            } else {
                offer(querySnapshot!!)
            }
        }
        awaitClose {
            callback.remove()
        }
    }
}