subscribe method

Future<void> subscribe(
  1. MessageHandler middleware
)

Register a handler to subscribe to messages sent to the topic.

Implementation

Future<void> subscribe(MessageHandler middleware) async {
  var registrationRequest = $tp.RegistrationRequest(topicName: name);

  var worker = SubscriptionWorker(registrationRequest, middleware,
      client: _subscriberClient);

  await worker.start();
}