onConnectionHandlers method

void onConnectionHandlers(void connected())

Implementation

void onConnectionHandlers(void Function() connected) {
  socket?.on('connect', (data) {
    if (needResubscribe) {
      if (kDebugMode) {
        print('connect re_sub');
      }
      needCallDisconnect = false;
      removeSocket();
      connectSocket(connected);
      needCallDisconnect = true;
    } else {
      //print('connected');
      socketConnected = true;
      for (var subscriptionId in subs.keys) {
        var subscription = subs[subscriptionId];
        var type = subscription!.type;
        var options = subscription.options;
        var data = <String, dynamic>{
          'id': subscriptionId,
          'name': type,
          'options': options,
        };

        subscribe(data, subscription);
      }

      socket!.on('SUB_RES', (data) {
        if (E != dynamic && E != Map) {
          subs[data['id']]!
              .callback
              ?.call(reflector.deserialize<E>(data['data']));
        } else {
          subs[data['id']]!.callback?.call(data['data']);
        }
      });
      needResubscribe = false;
      connected.call();
      _controller.add('connect');
    }
  });
}