addMessageListener method

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

Implementation

void addMessageListener(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_MESSAGES.toShortString(),
            options,
            callback);
    subscription.subscribe();
  } else {
    await addWaitingSubscription(
      SubscriptionNames.PUB_SUB_MESSAGES.toShortString(),
      callback,
    );
  }
}