U g@sdZddlmZmZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZedddZGd dde deZGd d d eZd S) z-This module contains the BaseProcessor class.)ABCabstractmethod)BoundedSemaphore) TracebackType)AnyAsyncContextManager AwaitableOptionalTypeTypeVarfinal_BUPTBaseUpdateProcessor)boundc@seZdZdZdZedddZeedddZe e e e e e e d d d d Z eed ddZeedd dddZed d ddZed d ddZeedd dddZd S)raAn 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 _semaphore)max_concurrent_updatescCs(||_|jdkrtdt|j|_dS)Nz4`max_concurrent_updates` must be a positive integer!)rr ValueErrorrr)selfrrE/tmp/pip-unpacked-wheel-swnnwir2/telegram/ext/_baseupdateprocessor.py__init__Bs zBaseUpdateProcessor.__init__)rreturncs<z|IdHWn$tk r6|IdHYnX|S)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__Hs zBaseUpdateProcessor.__aenter__N)exc_typeexc_valexc_tbrcs|IdHdS)zD|async_context_manager| :meth:`shuts down ` the Processor.N)r)rrr r!rrr __aexit__YszBaseUpdateProcessor.__aexit__rcCs|jS)zM:obj:`int`: The maximum number of updates that can be processed concurrently.)rrrrrrbsz*BaseUpdateProcessor.max_concurrent_updatesAwaitable[Any]update coroutinercsdS)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_updategsz%BaseUpdateProcessor.do_process_updatecsdS)zInitializes the processor so resources can be allocated. Must be implemented by a subclass. .. seealso:: :meth:`shutdown` NrrrrrryszBaseUpdateProcessor.initializecsdS)zShutdown the processor so resources can be freed. Must be implemented by a subclass. .. seealso:: :meth:`initialize` NrrrrrrszBaseUpdateProcessor.shutdownc s6|j4IdH|||IdHW5QIdHRXdS)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_updatesz"BaseUpdateProcessor.process_update)__name__ __module__ __qualname____doc__ __slots__intrr rr r BaseExceptionrr"propertyrrobjectr)rrr r*rrrrrs2#  c@sBeZdZdZdZedddddZddd d Zddd 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$Nr%cs|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_updater#csdSz Does nothing.Nrrrrrrsz SimpleUpdateProcessor.initializecsdSr5rrrrrrszSimpleUpdateProcessor.shutdown) r+r,r-r.r/r3r)rrrrrrr4s r4N)r.abcrrZasynciortypesrtypingrrrr r r r r rr4rrrrs  $