addUserStatusListener method

Future<void> addUserStatusListener(
  1. void callback(
    1. UserStatusResponse? response
    ), {
  2. void onError(
    1. 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);
  }
}