o Zzj@sdZddlmZmZddlmZddlmZddlm Z m Z m Z m Z ddl mZe r0ddlmZe dd d ZGd d d ed eZGd d d eZdS)z-This module contains the BaseProcessor class.)ABCabstractmethod)AbstractAsyncContextManager) TracebackType) TYPE_CHECKINGAnyTypeVarfinal)TrackedBoundedSemaphore) Awaitable_BUPTBaseUpdateProcessor)boundc@seZdZdZdZdefddZdedefdd Zd e e d Bd e d Bd e d Bdd fddZ e defddZe defddZededddd fddZedddZedddZededddd fddZd S) r aAn abstract base class for update processors. You can use this class to implement your own update processor. Instances of this class can be used as asyncio context managers, where .. code:: python async with processor: # code is roughly equivalent to .. code:: python try: await processor.initialize() # code finally: await processor.shutdown() .. seealso:: :meth:`__aenter__` and :meth:`__aexit__`. .. seealso:: :wiki:`Concurrency` .. versionadded:: 20.4 Args: max_concurrent_updates (:obj:`int`): The maximum number of updates to be processed concurrently. If this number is exceeded, new updates will be queued until the number of currently processed updates decreases. Raises: :exc:`ValueError`: If :paramref:`max_concurrent_updates` is a non-positive integer. )_max_concurrent_updates _semaphoremax_concurrent_updatescCs(||_|jdkr tdt|j|_dS)Nz4`max_concurrent_updates` must be a positive integer!)rr ValueErrorr r)selfrr\/var/www/kodo/tsheker/venv/lib/python3.10/site-packages/telegram/ext/_baseupdateprocessor.py__init__Hs zBaseUpdateProcessor.__init__rreturncs6z |IdHW|Sty|IdHw)a+|async_context_manager| :meth:`initializes ` the Processor. Returns: The initialized Processor instance. Raises: :exc:`Exception`: If an exception is raised during initialization, :meth:`shutdown` is called in this case. N) initialize Exceptionshutdownrrrr __aenter__Ns  zBaseUpdateProcessor.__aenter__exc_typeNexc_valexc_tbcs|IdHdS)zD|async_context_manager| :meth:`shuts down ` the Processor.N)r)rrrr rrr __aexit___szBaseUpdateProcessor.__aexit__cCs|jS)zM:obj:`int`: The maximum number of updates that can be processed concurrently.)rrrrrrhsz*BaseUpdateProcessor.max_concurrent_updatescCs|j|jjS)a:obj:`int`: The number of updates currently being processed. Caution: This value is a snapshot of the current number of updates being processed. It may change immediately after being read. .. versionadded:: 21.11 )rr current_valuerrrrcurrent_concurrent_updatesms z.BaseUpdateProcessor.current_concurrent_updatesupdate coroutineAwaitable[Any]cdS)aCustom implementation of how to process an update. Must be implemented by a subclass. Warning: This method will be called by :meth:`process_update`. It should *not* be called manually. Args: update (:obj:`object`): The update to be processed. coroutine (:term:`Awaitable`): The coroutine that will be awaited to process the update. Nrrr$r%rrrdo_process_updateyz%BaseUpdateProcessor.do_process_updatecr')zInitializes the processor so resources can be allocated. Must be implemented by a subclass. .. seealso:: :meth:`shutdown` Nrrrrrrr*zBaseUpdateProcessor.initializecr')zShutdown the processor so resources can be freed. Must be implemented by a subclass. .. seealso:: :meth:`initialize` Nrrrrrrr*zBaseUpdateProcessor.shutdownc sT|j4IdH|||IdHWdIdHdS1IdHs#wYdS)a0Calls :meth:`do_process_update` with a semaphore to limit the number of concurrent updates. Args: update (:obj:`object`): The update to be processed. coroutine (:term:`Awaitable`): The coroutine that will be awaited to process the update. N)rr)r(rrrprocess_updates.z"BaseUpdateProcessor.process_updaterN)__name__ __module__ __qualname____doc__ __slots__intrr rtype BaseExceptionrr!propertyrr#robjectr)rrr r+rrrrr "sL#       c@s>eZdZdZdZdeddddfdd Zdd d Zdd d ZdS)SimpleUpdateProcessoraInstance of :class:`telegram.ext.BaseUpdateProcessor` that immediately awaits the coroutine, i.e. does not apply any additional processing. This is used by default when :attr:`telegram.ext.ApplicationBuilder.concurrent_updates` is :obj:`int`. .. versionadded:: 20.4 rr$r%r&rNcs|IdHdS)aImmediately awaits the coroutine, i.e. does not apply any additional processing. Args: update (:obj:`object`): The update to be processed. coroutine (:term:`Awaitable`): The coroutine that will be awaited to process the update. Nrr(rrrr)s z'SimpleUpdateProcessor.do_process_updatecr'z Does nothing.Nrrrrrrr*z SimpleUpdateProcessor.initializecr'r8rrrrrrr*zSimpleUpdateProcessor.shutdownr,) r-r.r/r0r1r6r)rrrrrrr7s r7N)r0abcrr contextlibrtypesrtypingrrrr telegram.ext._utils.asyncior collections.abcr r r r7rrrrs