Skip to content

Commit 5549d17

Browse files
committed
Add toFlow extensions to DocumentSnapshot and Query
1 parent 9d93a95 commit 5549d17

File tree

1 file changed

+10
-4
lines changed
  • firebase-firestore/ktx/src/main/kotlin/com/google/firebase/firestore/ktx

1 file changed

+10
-4
lines changed

firebase-firestore/ktx/src/main/kotlin/com/google/firebase/firestore/ktx/Firestore.kt

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,14 @@ import androidx.annotation.Keep
1818
import com.google.firebase.FirebaseApp
1919
import com.google.firebase.components.Component
2020
import com.google.firebase.components.ComponentRegistrar
21-
import com.google.firebase.firestore.*
22-
import com.google.firebase.firestore.util.Logger
21+
import com.google.firebase.firestore.DocumentReference
22+
import com.google.firebase.firestore.DocumentSnapshot
23+
import com.google.firebase.firestore.FieldPath
24+
import com.google.firebase.firestore.FirebaseFirestore
25+
import com.google.firebase.firestore.Query
26+
import com.google.firebase.firestore.QueryDocumentSnapshot
27+
import com.google.firebase.firestore.QuerySnapshot
28+
import com.google.firebase.firestore.FirebaseFirestoreSettings
2329

2430
import com.google.firebase.ktx.Firebase
2531
import com.google.firebase.platforminfo.LibraryVersionComponent
@@ -170,7 +176,7 @@ fun DocumentReference.toFlow() = callbackFlow {
170176
if (value != null && value.exists()) {
171177
offer(value)
172178
} else if (error != null) {
173-
Logger.warn("DocumentReference:flow", error.message)
179+
close(error)
174180
}
175181
}
176182
awaitClose {
@@ -186,7 +192,7 @@ fun Query.toFlow() = callbackFlow {
186192
if (value != null) {
187193
offer(value)
188194
} else if (error != null) {
189-
Logger.warn("Query:flow", error.message)
195+
close(error)
190196
}
191197
}
192198
awaitClose {

0 commit comments

Comments
 (0)