Ë
    îñþib  ã                  ó‚   — d dl mZ d dlmZmZ d dlmZmZ d dlm	Z	 d dl
mZ  ed«      Z G d„ d«      Z G d	„ d
e«      Zy)é    )Úannotations)ÚCallableÚSequence)ÚAnyÚ	ParamSpec)Úis_async_callable)Úrun_in_threadpoolÚPc                  ó   — e Zd Zdd„Zdd„Zy)ÚBackgroundTaskc                óN   — || _         || _        || _        t        |«      | _        y ©N)ÚfuncÚargsÚkwargsr   Úis_async)Úselfr   r   r   s       úT/root/aria/mcps/aria-brain/venv/lib/python3.12/site-packages/starlette/background.pyÚ__init__zBackgroundTask.__init__   s#   € ØˆŒ	ØˆŒ	ØˆŒÜ)¨$Ó/ˆ�ó    c              ƒ  óô   K  — | j                   r/ | j                  | j                  i | j                  ¤Žƒ d {  –—†  y t	        | j                  g| j                  ¢­i | j                  ¤Žƒ d {  –—†  y 7 Œ;7 Œ­wr   )r   r   r   r   r	   )r   s    r   Ú__call__zBackgroundTask.__call__   s[   è ø€ Ø�=Š=Ø�$—)‘)˜TŸY™YÐ6¨$¯+©+Ñ6×6Ñ6ä# D§I¡IÐI°·	±	ÒI¸T¿[¹[ÑI×IÑIð 7øàIús!   ‚6A8¸A4¹5A8Á.A6Á/A8Á6A8N©r   zCallable[P, Any]r   zP.argsr   zP.kwargsÚreturnÚNone©r   r   )Ú__name__Ú
__module__Ú__qualname__r   r   © r   r   r   r      s   „ ó0ôJr   r   c                  ó&   — e Zd Zddd„Zdd„Zdd„Zy)	ÚBackgroundTasksNc                ó8   — |rt        |«      | _        y g | _        y r   )ÚlistÚtasks)r   r%   s     r   r   zBackgroundTasks.__init__   s   € Ù$)”T˜%“[ˆ�
¨rˆ�
r   c                óX   — t        |g|¢­i |¤Ž}| j                  j                  |«       y r   )r   r%   Úappend)r   r   r   r   Útasks        r   Úadd_taskzBackgroundTasks.add_task   s(   € Ü˜dÐ4 TÒ4¨VÑ4ˆØ�
‰
×Ñ˜$Õr   c              ƒ  óP   K  — | j                   D ]  } |«       ƒ d {  –—†  Œ y 7 Œ­wr   )r%   )r   r(   s     r   r   zBackgroundTasks.__call__"   s%   è ø€ Ø—J‘Jò 	ˆDÙ“&�L‰Lñ	Øús   ‚&œ$�&r   )r%   zSequence[BackgroundTask] | Noner   r   )r   r   r   r   r)   r   r    r   r   r"   r"      s   „ ô2ó ôr   r"   N)Ú
__future__r   Úcollections.abcr   r   Útypingr   r   Ústarlette._utilsr   Ústarlette.concurrencyr	   r
   r   r"   r    r   r   ú<module>r0      s5   ðÝ "ç .ß !å .Ý 3áˆcƒN€÷Jñ Jô
�nõ 
r   