@asynccontextmanager
    async def _connect_bus(self):
        self._bus = await MessageBus(
            bus_type=BusType.SYSTEM,
            negotiate_unix_fd=True,
            auth=get_dbus_authenticator(),
        ).connect()

        try:
            yield
        finally:
            self._cleanup_all()

    def connect():
        # ...rest of the code...
        async with async_timeout(timeout), AsyncExitStack() as stack:
            while True:
                # Each BLE connection session needs a new D-Bus connection to avoid a
                # BlueZ quirk where notifications are automatically enabled on reconnect.
                await stack.enter_async_context(self._connect_bus())

    def connect():
        async with async_timeout(timeout), AsyncExitStack() as stack:
            while True:
                self._bus = await MessageBus(
                    bus_type=BusType.SYSTEM,
                    negotiate_unix_fd=True,
                    auth=get_dbus_authenticator(),
                ).connect()

                stack.callback(self._cleanup_all)
                try:
                    try:
                        await self.get_services(
                            dangerous_use_bleak_cache=dangerous_use_bleak_cache
                        )

                        stack.pop_all() # added line
                        return True
                    except: BaseException:
                except BaseException:
                    local_disconnect_monitor_event.set()
                    # self._cleanup_all() line can be removed
                    raise