
    Dh                     .    d dl mZmZmZ  G d de      Zy)    )EventStreamEventStreamBufferNoInitialResponseErrorc                   *    e Zd Zd Zd Zd Zd Zd Zy)AioEventStreamc                     t        d      )NzUse async-for instead)NotImplementedErrorselfs    y/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/aiobotocore/eventstream.py__iter__zAioEventStream.__iter__	   s    !"9::    c                 "    | j                         S N)	__anext__r
   s    r   	__aiter__zAioEventStream.__aiter__   s    ~~r   c                p   K   | j                   2 3 d {   }| j                  |      }|s| #7 6 y wr   )_event_generator_parse_event)r   eventparsed_events      r   r   zAioEventStream.__anext__   s=     00 	# 	#%,,U3L""	#0s    64246646c                   K   t               }| j                  j                  j                         2 3 d {   \  }}|j	                  |       |D ]  }| 	 *7 %6 y wr   )r   _raw_streamcontentiter_chunksadd_data)r   event_stream_bufferchunk_r   s        r   _create_raw_event_generatorz*AioEventStream._create_raw_event_generator   sb     /1"..66BBD 	 	(%((/, 	Ds%   /AAAA"AAAc                    K   	 | j                   2 3 d {   }|j                  j                  d      }|dk(  r|c S  t	               7 36 	 t	               # t        $ r Y t	               w xY ww)Nz:event-typezinitial-response)r   headersgetStopIterationr   )r   r   
event_types      r   get_initial_responsez#AioEventStream.get_initial_response   s     	#44  e"]]..}=
!33 L %&&4 %&&  	$&&	sW   A.A A
AA
$A A.A 
A.A

A 
A.	A+A.*A++A.N)__name__
__module____qualname__r   r   r   r    r&    r   r   r   r      s    ; #
'r   r   N)botocore.eventstreamr   r   r   r   r*   r   r   <module>r,      s    '[ 'r   