subscribe<T> method

void subscribe<T>(
  1. Map<String, dynamic> data,
  2. RTSubscription<T> subscription
)

Implementation

void subscribe<T>(Map<String, dynamic> data, RTSubscription<T> subscription) {
  if (_instance.socketConnected) {
    socket!.emit('SUB_ON', data);
    //print('sub_on ${subscription.subscriptionId}');
  } else {
    connectSocket(() => socket!.emit('SUB_ON', data));
  }
}