
    pge                     6    d dl mZmZmZ  G d de          ZdS )    )EventStreamEventStreamBufferNoInitialResponseErrorc                   ,    e Zd Zd Zd Zd Zd Zd ZdS )AioEventStreamc                      t          d          )NzUse async-for instead)NotImplementedErrorselfs    7lib/python3.11/site-packages/aiobotocore/eventstream.py__iter__zAioEventStream.__iter__	   s    !"9:::    c                 *    |                                  S N)	__anext__r
   s    r   	__aiter__zAioEventStream.__aiter__   s    ~~r   c                b   K   | j         2 3 d {V }|                     |          }|r|W V  $6 d S r   )_event_generator_parse_event)r   eventparsed_events      r   r   zAioEventStream.__anext__   sg      0 	# 	# 	# 	# 	# 	# 	#%,,U33L #""""" 100s   .c                   K   t                      }| j        j                                        2 3 d {V \  }}|                    |           |D ]}|W V  *6 d S 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   s      /11".6BBDD 	 	 	 	 	 	 	(%((///,   EDDs   Ac                    K   	 | j         2 3 d {V }|j                            d          }|dk    r|c S  n6 n# t          $ r Y nw xY wt	                      )Nz:event-typezinitial-response)r   headersgetStopIterationr   )r   r   
event_types      r   get_initial_responsez#AioEventStream.get_initial_response   s      	#4       e"]..}==
!333 LLL  5  	 	 	D	$&&&s   : 8$: : 
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,      sk            ' ' ' ' '[ ' ' ' ' 'r   