§
    øyIfL  ã                  ó´   — d dl mZ d dlmZ d dlmZmZmZ d dlm	Z	m
Z
mZ d dlmZ e
r"d dlZd dlmZ ej        dk    rd d	lmZ nd d	lmZ  G d
„ d¦  «        ZdS )é    )Úannotations)Úcontextmanager)ÚEventÚLockÚTimer)ÚIOÚTYPE_CHECKINGÚIterator)ÚForeN)ÚTracebackType)é   é   )ÚSelfc                  ó¨   — e Zd ZdZdZd%d&d„Zd'd„Zd(d„Zd)d„Zd*d„Z	d+d„Z
d+d„Zd+d„Zd,d„Zed-d!„¦   «         Zed'd"„¦   «         Zed.d$„¦   «         ZdS )/Ú	SyncWritezÛ
    Make sure data collected is synced in-memory and to the target stream on every newline and time period.

    Used to propagate executed commands output to the standard output/error streams visible to the user.
    gš™™™™™¹?NÚnameÚstrÚtargetúIO[bytes] | NoneÚcolorú
str | NoneÚreturnÚNonec                óè   — t          ¦   «         | _        || _        |d u| _        t	          ¦   «         | _        t          ¦   «         | _        t          ¦   «         | _        d| _	        || _
        || _        d S )Nr   )Ú	bytearrayÚ_contentÚ_targetÚ_target_enabledr   Ú_keep_printingr   Ú_content_lockÚ_lockÚ_atÚ_colorr   )Úselfr   r   r   s       úF/var/www/piapp/venv/lib/python3.11/site-packages/tox/execute/stream.pyÚ__init__zSyncWrite.__init__   s]   € Ý!™œˆŒØ)/ˆŒØ%+°4Ð%7ˆÔÝ%*¡W¤WˆÔÝ#'¡6¤6ˆÔÝ™6œ6ˆŒ
ØˆŒØ"'ˆŒØˆŒ	ˆ	ˆ	ó    c                óP   — | j         j        › d| j        ›d| j        ›d| j        ›d�S )Nz(name=z	, target=z, color=ú))Ú	__class__Ú__name__r   r   r#   ©r$   s    r%   Ú__repr__zSyncWrite.__repr__'   s6   € Ø”.Ô)ÐoÐo°´ÐoÐoÀtÄ|ÐoÐoÐ_cÔ_jÐoÐoÐoÐor'   r   c                ó<   — | j         r|                      ¦   «          | S ©N)r   Ú_startr,   s    r%   Ú	__enter__zSyncWrite.__enter__*   s   € ØÔð 	Ø�KŠK‰MŒMˆMØˆr'   Úexc_typeútype[BaseException] | NoneÚexc_valúBaseException | NoneÚexc_tbúTracebackType | Nonec                óŽ   — | j         r=|                      ¦   «          |                      t          | j        ¦  «        ¦  «         d S d S r/   )r   Ú_cancelÚ_writeÚlenr   )r$   r2   r4   r6   s       r%   Ú__exit__zSyncWrite.__exit__/   sH   € ð Ôð 	,Ø�LŠL‰NŒNˆNØ�KŠK�˜DœMÑ*Ô*Ñ+Ô+Ð+Ð+Ð+ð	,ð 	,r'   ÚcontentÚbytesc                óê  — | j         5  | j                             |¦  «         | j        du r	 ddd¦  «         dS |                     d¦  «        }|dk    r*t          | j        ¦  «        t          |¦  «        z
  |z   dz   }ddd¦  «         n# 1 swxY w Y   |                      ¦   «          	 |dk    r|                      |¦  «         |                      ¦   «          dS # |                      ¦   «          w xY w)z.A callback called whenever content is written.FNó   
éÿÿÿÿé   )	r    r   Úextendr   Úrfindr;   r9   r:   r0   )r$   r=   Úats      r%   ÚhandlerzSyncWrite.handler9   sW  € àÔð 	@ð 	@ØŒM× Ò  Ñ)Ô)Ð)ØÔ# uÐ,Ð,Øð	@ð 	@ð 	@ñ 	@ô 	@ð 	@ð 	@ð 	@ð —’˜uÑ%Ô%ˆBØ�RŠxˆxÝ˜œÑ'Ô'­#¨g©,¬,Ñ6¸Ñ;¸aÑ?�ð	@ð 	@ð 	@ñ 	@ô 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@øøøð 	@ð 	@ð 	@ð 	@ð 	�Š‰Œˆð	Ø�RŠxˆxØ—’˜B‘”�à�KŠK‰MŒMˆMˆMˆMøˆD�KŠK‰MŒMˆMˆMøøøs#   ˆ%BºABÂBÂBÂ+C ÃC2c                óž   — t          | j        | j        ¦  «        | _        | j        › d�| j        _        | j                             ¦   «          d S )Nz-sync-timer)r   ÚREFRESH_RATEÚ_trigger_timerÚtimerr   Ústartr,   s    r%   r0   zSyncWrite._startI   sG   € Ý˜4Ô,¨dÔ.AÑBÔBˆŒ
Ø!œYÐ3Ð3Ð3ˆŒ
ŒØŒ
×ÒÑÔÐÐÐr'   c                ó8   — | j                              ¦   «          d S r/   )rJ   Úcancelr,   s    r%   r9   zSyncWrite._cancelN   s   € ØŒ
×ÒÑÔÐÐÐr'   c                ó–   — | j         5  t          | j        ¦  «        }d d d ¦  «         n# 1 swxY w Y   |                      |¦  «         d S r/   )r    r;   r   r:   ©r$   rE   s     r%   rI   zSyncWrite._trigger_timerQ   s‚   € ØÔð 	$ð 	$Ý�T”]Ñ#Ô#ˆBð	$ð 	$ð 	$ñ 	$ô 	$ð 	$ð 	$ð 	$ð 	$ð 	$ð 	$øøøð 	$ð 	$ð 	$ð 	$à�Š�B‰Œˆˆˆs   ˆ)©-°-rE   Úintc                óz  — | j         €J ‚| j        5  || j        k    r†	 |                      ¦   «         5  | j                              | j        | j        |…         ¦  «         d d d ¦  «         n# 1 swxY w Y   | j                              ¦   «          || _        n# || _        w xY wd d d ¦  «         d S # 1 swxY w Y   d S r/   )r   r!   r"   ÚcoloredÚwriter   ÚflushrO   s     r%   r:   zSyncWrite._writeV   sO  € ØŒ|Ð'Ð'Ð'ØŒZð 	"ð 	"Ø�D”HŠ}ˆ}ð"ØŸš™œð Ið IØœ×*Ò*¨4¬=¸¼ÀB¸Ô+GÑHÔHÐHðIð Ið Iñ Iô Ið Ið Ið Ið Ið Ið Iøøøð Ið Ið Ið Ià”L×&Ò&Ñ(Ô(Ð(à!�D”H�Hø˜r�D”H�M�M�M�Mð	"ð 	"ð 	"ñ 	"ô 	"ð 	"ð 	"ð 	"ð 	"ð 	"ð 	"ð 	"øøøð 	"ð 	"ð 	"ð 	"ð 	"ð 	"sK   ‘B0žB²-A+ÁBÁ+A/	Á/BÁ2A/	Á3BÂB0Â	B Â B0Â0B4Â7B4úIterator[None]c              #  ó†  K  — | j         �| j        €d V — d S | j                             | j                              d¦  «        ¦  «         	 d V — | j                             t          j                             d¦  «        ¦  «         d S # | j                             t          j                             d¦  «        ¦  «         w xY w)Núutf-8)r#   r   rS   Úencoder   ÚRESETr,   s    r%   rR   zSyncWrite.coloreda   s®   è è € àŒ;Ð $¤,Ð"6ØˆEˆEˆEˆEˆEàŒL×Ò˜tœ{×1Ò1°'Ñ:Ô:Ñ;Ô;Ð;ð?Ø���à”×"Ò"¥4¤:×#4Ò#4°WÑ#=Ô#=Ñ>Ô>Ð>Ð>Ð>ø�”×"Ò"¥4¤:×#4Ò#4°WÑ#=Ô#=Ñ>Ô>Ð>Ð>øøøs   Á
B Â9C c                ó|   — | j         5  | j                             dd¬¦  «        cd d d ¦  «         S # 1 swxY w Y   d S )NrW   Úsurrogateescape)Úerrors)r    r   Údecoder,   s    r%   ÚtextzSyncWrite.textl   sœ   € àÔð 	Kð 	KØ”=×'Ò'¨Ð8IÐ'ÑJÔJð	Kð 	Kð 	Kð 	Kñ 	Kô 	Kð 	Kð 	Kð 	Kð 	Kð 	Kð 	Køøøð 	Kð 	Kð 	Kð 	Kð 	Kð 	Ks   ˆ1±5¸5r   c                óR   — | j         5  | j        cd d d ¦  «         S # 1 swxY w Y   d S r/   )r    r   r,   s    r%   r=   zSyncWrite.contentq   st   € àÔð 	!ð 	!Ø”=ð	!ð 	!ð 	!ð 	!ñ 	!ô 	!ð 	!ð 	!ð 	!ð 	!ð 	!ð 	!øøøð 	!ð 	!ð 	!ð 	!ð 	!ð 	!s   ˆœ £ r/   )r   r   r   r   r   r   r   r   )r   r   )r   r   )r2   r3   r4   r5   r6   r7   r   r   )r=   r>   r   r   )r   r   )rE   rP   r   r   )r   rU   )r   r   )r+   Ú
__module__Ú__qualname__Ú__doc__rH   r&   r-   r1   r<   rF   r0   r9   rI   r:   r   rR   Úpropertyr^   r=   © r'   r%   r   r      sF  € € € € € ðð ð €Lð	ð 	ð 	ð 	ð 	ðpð pð pð pðð ð ð ð
,ð ,ð ,ð ,ðð ð ð ð ð ð ð ð
ð ð ð ðð ð ð ð
	"ð 	"ð 	"ð 	"ð ð?ð ?ð ?ñ „^ð?ð ðKð Kð Kñ „XðKð ð!ð !ð !ñ „Xð!ð !ð !r'   r   )Ú
__future__r   Ú
contextlibr   Ú	threadingr   r   r   Útypingr   r	   r
   Úcoloramar   ÚsysÚtypesr   Úversion_infor   Útyping_extensionsr   rd   r'   r%   ú<module>rn      s  ðØ "Ð "Ð "Ð "Ð "Ð "à %Ð %Ð %Ð %Ð %Ð %Ø (Ð (Ð (Ð (Ð (Ð (Ð (Ð (Ð (Ð (Ø .Ð .Ð .Ð .Ð .Ð .Ð .Ð .Ð .Ð .à Ð Ð Ð Ð Ð àð +Ø€J€J€JØ#Ð#Ð#Ð#Ð#Ð#à
Ô˜7Ò"Ð"ØÐÐÐÐÐÐà*Ð*Ð*Ð*Ð*Ð*ða!ð a!ð a!ð a!ð a!ñ a!ô a!ð a!ð a!ð a!r'   