@override Future<void> connect() async { _connected = true; _connectionStateController.add(ChatConnectionState.connected); }