subscribe method

Future<Subscription> subscribe(
  1. String topic,
  2. void endpoint(
    1. Event event
    )
)

Implementation

Future<Subscription> subscribe(String topic, void Function(Event event) endpoint) {
  var subscribe = msg.Subscribe(_nextID, topic);

  var completer = Completer<Subscription>();
  _subscribeRequests[subscribe.requestID] = SubscribeRequest(completer, endpoint);
  _baseSession.send(_wampSession.sendMessage(subscribe));

  return completer.future;
}