fix(llc): watch support for queryCalls method (#722)

* watch support for queryCalls method

* Update docusaurus/docs/Flutter/03-core-concepts/06-querying-calls.mdx

---------

Co-authored-by: Deven Joshi <[email protected]>

Author: Brazol

docusaurus/docs/Flutter/03-core-concepts/06-querying-calls.mdx

@@ -74,4 +74,13 @@ final result = await video.queryCalls(
 );
 ```
 
-The `queryCalls` function can take multiple sort parameters, which can be combined with filtering to give you powerful control over the data in your application.
+The `queryCalls` function can take multiple sort parameters, which can be combined with filtering to give you powerful control over the data in your application.
+
+### Watching calls
+​
+If you specify `watch` parameter as `true`, the SDK will create a subscription to the call data on the server and you'll be able to receive updates in real-time.
+
+The server will send updates to the client when the call data changes (for example, members are updated, a call session has started, etc...). This is useful for showing a live preview of who is in the call or building a call dashboard.
+
+You can listen to call events via the `StreamVideo.instance.events` stream.
+

packages/stream_video/lib/src/coordinator/coordinator_client.dart

@@ -187,6 +187,7 @@ abstract class CoordinatorClient {
     String? prev,
     List<open.SortParam> sorts = const [],
     int? limit,
+    bool? watch,
   });
 
   Future<Result<None>> blockUser({

packages/stream_video/lib/src/coordinator/open_api/coordinator_client_open_api.dart

@@ -875,6 +875,7 @@ class CoordinatorClientOpenApi extends CoordinatorClient {
     String? prev,
     List<open.SortParam> sorts = const [],
     int? limit,
+    bool? watch,
   }) async {
     try {
       final connectionResult = await _waitUntilConnected();
@@ -889,6 +890,7 @@ class CoordinatorClientOpenApi extends CoordinatorClient {
           prev: prev,
           sort: sorts,
           limit: limit,
+          watch: watch,
         ),
       );
       if (result == null) {

packages/stream_video/lib/src/coordinator/retry/coordinator_client_retry.dart

@@ -334,6 +334,7 @@ class CoordinatorClientRetry extends CoordinatorClient {
     String? prev,
     List<open.SortParam> sorts = const [],
     int? limit,
+    bool? watch,
   }) {
     return _retryManager.execute(
       () => _delegate.queryCalls(
@@ -342,6 +343,7 @@ class CoordinatorClientRetry extends CoordinatorClient {
         prev: prev,
         sorts: sorts,
         limit: limit,
+        watch: watch,
       ),
       (error, nextAttemptDelay) async {
         _logRetry('queryCalls', error, nextAttemptDelay);

packages/stream_video/lib/src/stream_video.dart

@@ -527,13 +527,15 @@ class StreamVideo extends Disposable {
     String? prev,
     int? limit,
     List<open.SortParam>? sorts,
+    bool? watch,
   }) {
     return _client.queryCalls(
       filterConditions: filterConditions,
       next: next,
       limit: limit,
       prev: prev,
       sorts: sorts ?? [],
+      watch: watch,
     );
   }