Fix e2e test for listen

aashishpatil-g · aashishpatil-g · commit aa10e4ac1c8f · 2026-01-15T21:57:07.000-08:00
diff --git a/packages/firebase_data_connect/firebase_data_connect/lib/src/core/ref.dart b/packages/firebase_data_connect/firebase_data_connect/lib/src/core/ref.dart
@@ -311,9 +311,7 @@ class QueryRef<Data, Variables> extends OperationRef<Data, Variables> {
   Stream<QueryResult<Data, Variables>> subscribe() {
     _streamController ??= _queryManager.addQuery(this);
 
-    execute()
-        .then(_streamController!.add)
-        .catchError(_streamController!.addError);
+    execute();
 
     return _streamController!.stream.cast<QueryResult<Data, Variables>>();
   }

Original file line number	Diff line number	Diff line change
`@@ -311,9 +311,7 @@ class QueryRef<Data, Variables> extends OperationRef<Data, Variables> {`
`311`	`311`	`Stream<QueryResult<Data, Variables>> subscribe() {`
`312`	`312`	`_streamController ??= _queryManager.addQuery(this);`
`313`	`313`
`314`		`- execute()`
`315`		`- .then(_streamController!.add)`
`316`		`- .catchError(_streamController!.addError);`
	`314`	`+ execute();`
`317`	`315`
`318`	`316`	`return _streamController!.stream.cast<QueryResult<Data, Variables>>();`
`319`	`317`	`}`