addUserStatusListener method
Future<void>
addUserStatusListener(
- void callback(
- UserStatusResponse? response
- void onError(
- String error
Implementation
Future<void> addUserStatusListener(
void Function(UserStatusResponse? response) callback,
{void Function(String error)? onError}) async {
if (RTListener.clientInstance!.socketConnected && _channel.isJoined) {
var options = <String, dynamic>{'channel': _channelName};
var subscription = await RTListener.clientInstance!
.createSubscription<UserStatusResponse>(
SubscriptionNames.PUB_SUB_USERS.toShortString(),
options,
callback);
subscription.subscribe();
} else {
await addWaitingSubscription(
SubscriptionNames.PUB_SUB_USERS.toShortString(), callback);
}
}