addMessageListener method
void
addMessageListener(
- void callback(
- 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,
);
}
}