Method _process_updates

telebot/async_telebot.py:523–535

Process updates. :param handlers: :param messages: :return:

(self, handlers, messages, update_type)

        return asyncio.create_task(coro)

    async def _process_updates(self, handlers, messages, update_type):
        """
        Process updates.

        :param handlers:
        :param messages:
        :return:
        """
        tasks = []
        middlewares = await self._get_middlewares(update_type)
        for message in messages:
            tasks.append(self._run_middlewares_and_handlers(message, handlers, middlewares, update_type))
        await asyncio.gather(*tasks)

    async def _run_middlewares_and_handlers(self, message, handlers, middlewares, update_type):
        """