feat(fdc): Handle disconnects and reconnects (#18157)

* Handle disconnects and reconnects

* Address gemini review comments

* Reconnection logic

* Fixes to reconnect on startup

* Fix to decode binary data from server

* Handle gemini feedback

* Update rest_transport mocks with new windows provider sig

Author: aashishpatil-g

packages/firebase_data_connect/firebase_data_connect/lib/src/core/ref.dart

@@ -334,14 +334,14 @@ class QueryRef<Data, Variables> extends OperationRef<Data, Variables> {
         _streamController!.stream.cast<QueryResult<Data, Variables>>();
 
     // Return the stream to the caller, then execute fetches
-    Future.microtask(() {
+    Future.microtask(() async {
       if (dataConnect.cacheManager != null) {
-        _executeFromCache(QueryFetchPolicy.cacheOnly)
-            .then((_) {})
-            .catchError((err) {
+        try {
+          await _executeFromCache(QueryFetchPolicy.cacheOnly);
+        } catch (err) {
           log("Error fetching from cache during subscribe $err");
           // Ignore cache misses here, server stream will provide latest data
-        });
+        }
       }
 
       // Initiate Web Socket stream
@@ -380,7 +380,7 @@ class QueryRef<Data, Variables> extends OperationRef<Data, Variables> {
         publishErrorToStream(e);
       }
     } catch (e) {
-      publishErrorToStream(e as Error);
+      publishErrorToStream(e);
     }
   }