@override Future<void> disconnect() async { _connected = false; _connectionStateController.add(ChatConnectionState.disconnected); }