openPersistenceConnection method

Future<void> openPersistenceConnection(
  1. User user
)

Connects the chatPersistenceClient to the given user.

Implementation

Future<void> openPersistenceConnection(User user) async {
  final client = chatPersistenceClient;
  if (client == null) {
    throw const StreamChatError('Chat persistence client is not set');
  }

  if (client.isConnected) {
    // If the persistence client is already connected to the userId,
    // we don't need to connect again.
    if (client.userId == user.id) return;

    throw const StreamChatError('''
      Chat persistence client is already connected to a different user,
      please close the connection before connecting a new one.''');
  }

  // Connect the persistence client to the userId.
  return client.connect(user.id);
}