subscribe method

Stream<DSMessageBrokerMessage> subscribe(
  1. String subscription, {
  2. int maxMessages = 10,
  3. Duration? pollInterval,
})

Subscribe to a subscription stream.

Implementation

Stream<DSMessageBrokerMessage> subscribe(
  String subscription, {
  int maxMessages = 10,
  Duration? pollInterval,
}) {
  log('Subscribing to: $subscription');
  return _provider.subscribe(
    subscription,
    maxMessages: maxMessages,
    pollInterval: pollInterval,
  );
}