
    Y5jY                    ^    S r SSKJr  SSKrSSKrSSKJr  SSKJr  SSS.       S
S	 jjr	g)zLEmite heartbeats mientras un generador bloqueante tarda en producir eventos.    )annotationsN)Iterator)Anyg      (@u"   Sigo trabajando en tu solicitud…)interval_secondsmessagec             #  $  ^ ^#    [         R                  " 5       mS	UU 4S jjn[        R                  " USS9R	                  5           TR                  US9u  pEUS:X  a  g US:X  a  UeUv   M'  ! [         R                   a    SUS.v    MF  f = f7f)
Nc                    >  T H  n TR                  SU 45        M     TR                  S5        g ! [         a  nTR                  SU45         S nAN4S nAff = f! TR                  S5        f = f)Nitemerror)endN)put	Exception)r
   excevent_queuesources     TC:\Users\jesus\Desktop\proyecto_pie360\backend\app\backend\utils\stream_keepalive.pyworker#iter_with_keepalive.<locals>.worker   sd    	+/ 
 OOM*  	,OOWcN++	, OOM*s&   1 
AAA AA A.T)targetdaemon)timeout	heartbeat)typer   r   r   )returnNone)queueQueue	threadingThreadstartgetEmpty)r   r   r   r   kindpayloadr   s   `     @r   iter_with_keepaliver%      s      16K+ + F40668
	'OO4DOEMD
 5=7?M  {{ 	&7;;	s*   ABA. B.B	BBB)r   Iterator[dict[str, Any]]r   floatr   strr   r&   )
__doc__
__future__r   r   r   collections.abcr   typingr   r%        r   <module>r/      sJ    R "   $  #7	$  	
 r.   