YiSrSSKJrJr SSKJr SSKJr SSKJ r SSK J r J r J r JrJr \ (aSSKJr \"SS S 9r"S S \S \5r"S S \5rg)z-This module contains the BaseProcessor class.)ABCabstractmethod)BoundedSemaphore)AbstractAsyncContextManager) TracebackType) TYPE_CHECKINGAnyOptionalTypeVarfinal) Awaitable_BUPTBaseUpdateProcessor)boundc\rSrSrSrSrS\4SjrS\S\4Sjr S \ \ \ S \ \ S \ \ SS 4S jr\S\4Sj5r\S\SSSS 4Sj5r\SSj5r\SSj5r\S\SSSS 4Sj5rSrg )r aLAn 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_updatesczXlURS:a [S5e[UR5Ulg)Nz4`max_concurrent_updates` must be a positive integer!)rr ValueErrorrr)selfrs L/app/.venv/lib/python3.13/site-packages/telegram/ext/_baseupdateprocessor.py__init__BaseUpdateProcessor.__init__Fs4'=$  & & *ST T*4+F+FGrreturnc# UR5IShvN U$N![a UR5IShvN ef=f7f)z|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 Exceptionshutdownrs r __aenter__BaseUpdateProcessor.__aenter__LsF //# # # $ --/ ! !  s/A  A AAAAexc_typeexc_valexc_tbNc@# UR5IShvN gN7f)zD|async_context_manager| :meth:`shuts down ` the Processor.N)r")rr&r'r(s r __aexit__BaseUpdateProcessor.__aexit__]smmos cUR$)zM:obj:`int`: The maximum number of updates that can be processed concurrently.)rr#s rr*BaseUpdateProcessor.max_concurrent_updatesfs+++rupdate coroutineAwaitable[Any]c # g7f)afCustom 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. Nrr.r/s rdo_process_update%BaseUpdateProcessor.do_process_updatekc # g7f)zInitializes the processor so resources can be allocated. Must be implemented by a subclass. .. seealso:: :meth:`shutdown` Nr2r#s rr BaseUpdateProcessor.initialize}r6r7c # g7f)zzShutdown the processor so resources can be freed. Must be implemented by a subclass. .. seealso:: :meth:`initialize` Nr2r#s rr"BaseUpdateProcessor.shutdownr6r7c# URIShvN URX5IShvN SSS5IShvN gN.NN !,IShvN (df  g=f7f)aCalls :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)rr4r3s rprocess_update"BaseUpdateProcessor.process_updates;???((; ; ;#?? ;#???sQA"AA"AAA A"AA"AA"AA  AA"rN)__name__ __module__ __qualname____firstlineno____doc__ __slots__intrrr$r type BaseExceptionrr*propertyrrobjectr4r r"r r=__static_attributes__r2rrrr s!F:IHsH u"4 ./-('   ,,,  $     "     <<$<  < r\sT&4#$2??)45}<56KLc}<@/r