async def METHOD_NAME(self, *args, **kw):
    if self._current_page is None:
        self._response = await self._get_next(self.continuation_token)
        self.continuation_token, self._current_page = await self._extract_data(self._response)
    return await f(self, *args, **kw)