subscribe method

Future<void> subscribe(
  1. List<String> queries
)

Implementation

Future<void> subscribe(List<String> queries) async {
  _activeSubscriptionQueries.addAll(queries);

  final message = SubscribeMessage(queries);
  _connection.send(message.encode());

  await onInitialSubscription.first;
}