Cloud Firestore🔥 with Kotlin Coroutines and Flow API
We’ve heard a lot about Kotlin flow since its launch in March last year.
So what is a flow?
A flow is a type that can emit multiple values sequentially, as opposed to suspend functions that return only a single value.
If you’ve used Firestore before you would know that you can retrieve data once or have realtime updates for that data using its realtime listener.
Real time listener for a document with Firestore
Before we begin, make sure you have the coroutines dependency
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.4.2'Now let’s begin by creating a State class for handling the states of operations that happen.
Let’s make the repository that gets and listens to updates in realtime for our document.
As you can see above I’ve used callbackFlow as you cannot use emit() with the snapshot listener as it is already an async call. Therefore the callbackFlow provides a synchronized way of doing it with offer().
We are also closing the flow stream if any exception occurs while attempting to read data. In the end we are removing the listener that was attached in awaitClose. This lambda is called when the parent coroutine is cancelled.
Now the viewmodel for the interaction between activity and repository.
Here the viewmodel receives the Flow with its state.
Now the code inside the callbackFlow {…} in the repository is not called until that flow is collected.
Now in the activity / UI, the collect method is a suspended method thus it has to be called from a suspend method.
Now you can collect the post data from the flow as updates happen in real time and handle it if the State is successful.
And that’s all, I hope you find this article interesting and useful. If you like this post do share it with others! Thank you for reading!
You can also read this amazing article by Shreyas Patil
