subscribeEvents function

Future<EventBusSubscribeStream> subscribeEvents(
  1. EventBusClient client,
  2. List<TagValue> filterTags
)

Subscribe through a generated EventBusClient; returns the receiving stream (listen to its responses, or close() it to unsubscribe).

Implementation

Future<EventBusSubscribeStream> subscribeEvents(
        EventBusClient client, List<TagValue> filterTags) =>
    client.subscribe(SubscribeRequest()
      ..filter = List<TagValue>.from(filterTags));