fix: Prevent watch stream from closing on recoverable error

copilotmoney · Mar 14, 2024 · b4d785d · b4d785d
1 parent be49849
commit b4d785d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/Firestore/core/src/remote/grpc_stream.cc b/Firestore/core/src/remote/grpc_stream.cc
@@ -337,7 +337,11 @@ std::shared_ptr<GrpcCompletion> GrpcStream::NewCompletion(
                          const std::shared_ptr<GrpcCompletion>& completion) {
         RemoveCompletion(completion);
 
-        if (ok) {
+        if (ok || (completion->status()->ok() && completion->message()->Valid())) {
+          if (!ok) {
+            LOG_DEBUG("GrpcStream('%s'): operation of type %s failed, continuing", this,
+                      completion->type());
+          }
           if (on_success) {
             on_success(completion);
           }