U
|
M ±d ã @ s d dl mZmZmZmZmZ ddlmZmZm Z ddl
|
m Z m Z m Z mZmZmZmZ ddlmZmZmZmZmZ ddlmZ zd dl mZ W n ek
|
r¬ d dl mZ Y nX eee dd d
|
Z ee ee d d d Z ee ee dddZ G dd dZ!dS )é )ÚcastÚListÚTypeÚUnionÚ
|
ValuesViewé )Ú
|
ConnectionÚ NEED_DATAÚPAUSED)ÚConnectionClosedÚDataÚ EndOfMessageÚEventÚInformationalResponseÚRequestÚResponse)ÚCLIENTÚCLOSEDÚDONEÚ
|
MUST_CLOSEÚSERVER)ÚSentinel)ÚLiteral)ÚconnÚreturnc C sB g }| ¡ }|ttfkrq>tt|}| |¡ t|tkrq>q|S ©N)Z
|
next_eventr r
|
r r ÚappendÚtyper )r Ú
|
got_eventsÚevent© r úHd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\h11/tests/helpers.pyÚget_all_events s
|
|
r" )r Údatar c C s | |¡ t| S r )Ú receive_datar" )r r# r r r! Úreceive_and_get# s
|
r% )Ú in_eventsr c C s g }| D ]}t |tkr,tt|jddd}|rt |d t | krPtkrn n,t|d j|j |d j|d jd|d< q| |¡ q|S )NF)r# Ú chunk_startÚ chunk_endéÿÿÿÿ)r r Úbytesr# r' r( r )r& Z
|
out_eventsr r r r! Únormalize_data_events* s (ý r+ c @ sh e Zd ZddddZeee dddZd ee e
|
e e e f e
|
e e e e d f edd d
|
ZdS ) ÚConnectionPairN)r c C s( t tt ttti| _t ttt i| _d S r )r r r r Úother©Úselfr r r! Ú__init__? s zConnectionPair.__init__c C s
|
| j ¡ S r )r Úvaluesr. r r r! ÚconnsC s zConnectionPair.connsÚmatch)ÚroleÚ send_eventsÚexpectr c C s¼ t |ts|g}d}d}|D ]*}| j| |¡}|d kr>d}q ||7 }q |rb| j| j| |¡ |r|| j| j| d¡ t| j| j| }|dkr|}t |ts¬|g}||ks¸t|S )Nó FTr3 )Ú
|
isinstanceÚlistr Úsendr- r$ r" ÚAssertionError) r/ r4 r5 r6 r# ÚclosedZ
|
send_eventZnew_datar r r r! r: H s(
|
|
|
zConnectionPair.send)r3 )Ú__name__Ú
|
__module__Ú __qualname__r0 Úpropertyr r r2 r r r r r r r* r: r r r r! r, > s üûr, N)"Útypingr r r r r Ú _connectionr r r
|
Z_eventsr r r r r r r Ú_stater r r r r Z_utilr r Ú ImportErrorZtyping_extensionsr" r* r% r+ r, r r r r! Ú<module> s $
|
