o di@s4ddlmZmZmZddlmZGdddeZdS)) EventStreamEventStreamBufferNoInitialResponseError)EventStreamErrorc@s<eZdZddZddZddZddZd d Zd d Zd S)AioEventStreamcCstd)NzUse async-for instead)NotImplementedErrorselfr K/home/ubuntu/.local/lib/python3.10/site-packages/aiobotocore/eventstream.py__iter__ zAioEventStream.__iter__cCs|SN) __anext__rr r r __aiter__ r zAioEventStream.__aiter__cCs6|j2z3dHW}||IdH}|r|Vq6dSr)_event_generator _parse_event)r event parsed_eventr r r rszAioEventStream.__anext__cCsFt}|jj2z3dHW\}}|||D]}|Vqq 6dSr)r _raw_streamcontent iter_chunksadd_data)r event_stream_bufferchunk_rr r r _create_raw_event_generators z*AioEventStream._create_raw_event_generatorcs<|}|j||jIdH}|ddkr|St||j)N status_code)to_response_dict_parserparse _output_shaper_operation_name)r r response_dictparsed_responser r r rs  zAioEventStream._parse_eventcs^z"|j2z3dHW}|jd}|dkr|WSWt6Wtty.Ytw)Nz :event-typezinitial-response)rheadersget StopIterationr)r r event_typer r r get_initial_response's   z#AioEventStream.get_initial_responseN) __name__ __module__ __qualname__r rrrrr*r r r r r s rN)botocore.eventstreamrrrbotocore.exceptionsrrr r r r s