addCommandListener method

void addCommandListener(
  1. void callback(
    1. dynamic response
    )
)

Implementation

void addCommandListener(void Function(dynamic response) callback) async {
  if (RTListener.clientInstance!.socketConnected && _channel.isJoined) {
    var options = <String, dynamic>{'channel': _channelName};
    var subscription =
        await RTListener.clientInstance!.createSubscription<Map>(
      SubscriptionNames.PUB_SUB_COMMANDS.toShortString(),
      options,
      callback,
    );
    subscription.subscribe();
  } else {
    await addWaitingSubscription(
      SubscriptionNames.PUB_SUB_COMMANDS.toShortString(),
      callback,
    );
  }
}