Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
0.1.3 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
asgiref
/
__pycache__
/
testing.cpython-311.pyc
|
|---|
§
O>g
ã óP d dl Z d dlZd dlZddlmZ ddlmZ G d d¦ « ZdS )é Né )Úguarantee_single_callable)Útimeoutc óD e Zd ZdZd ZddZddZd Zd Zdd Z dd Z
d
S )ÚApplicationCommunicatorz}
Runs an ASGI application in a test mode, allowing sending of
messages to it and retrieval of messages it sends.
c óZ t |¦ « | _ || _ t j ¦ « | _ t j ¦ « | _ t j ¦ « t j
| || j j | j j ¦ « ¦ « | _
d S ©N)r Ú applicationÚscopeÚasyncioÚQueueÚ input_queueÚ output_queueÚ contextvarsÚContextÚrunÚ create_taskÚgetÚputÚfuture)Úselfr
r s ú6/tmp/pip-target-qlpkiub5/lib/python/asgiref/testing.pyÚ__init__z ApplicationCommunicator.__init__ s Ý4°[ÑAÔAÔØ
Ý"=??ÔÝ #MOOÔõ
"Ô)Ñ+Ô+×/Ò/Ý Ô Ø × Ò U DÔ$4Ô$8¸$Ô:KÔ:OÑ PÔ Pñ
ô
ó r c ó^ K t |¦ « 4 d{V | j d{V | j ¦ « n# t j $ r Y nw xY wddd¦ « d{V n# 1 d{V swxY w Y | j ¦ « s?| j ¦ « | j d{V dS # t j $ r Y dS w xY wdS # | j ¦ « s=| j ¦ « | j d{V w # t j $ r Y w w xY ww xY w)zV
Waits for the application to stop itself and returns any exceptions.
N)Ú
async_timeoutr Úresultr ÚCancelledErrorÚdoneÚcancel)r r s r Úwaitz ApplicationCommunicator.wait s è è ð
Ý$ WÑ-Ô-ð
ð
ð
ð
ð
ð
ð
ð
ðØ +Ð%Ð%Ð%Ð%Ð%Ð%Ð%ØK×&Ò&Ñ(Ô(Ð(Ð(øÝ Ô-ð ð ð ØDðøøøð
ð
ð
ñ
ô
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
ð
øøøð
ð
ð
ð
ð ;×#Ò#Ñ%Ô%ð
Ø ×"Ò"Ñ$Ô$Ð$ðØ +Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%øÝ Ô-ð ð ð ØDDðøøøð
ð
ø4;×#Ò#Ñ%Ô%ð
Ø ×"Ò"Ñ$Ô$Ð$ðØ +Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%øÝ Ô-ð ð ð ØDðøøøð
øøøs C A)&AÁA)ÁAÁA)ÁAÁA)ÁC Á)
A3Á3C Á6A3Á7C Â-
B< Â<CÃCÃ3D,Ä
DÄD,ÄD(Ä%D,Ä'D(Ä(D,Tc ó¨ | j ¦ « s| j ¦ « d S |r| j ¦ « d S d S r )r r r r )r Ú
exceptionss r Ústopz ApplicationCommunicator.stop0 s^ Ø{× Ò Ñ!Ô!ð !Ø K× Ò Ñ Ô Ð Ð Ð Ø
ð !à K× Ò Ñ Ô Ð Ð Ð ð !ð !r c óV | d¬¦ « d S # t $ r Y d S w xY w)NF)r# )r$ Ú RuntimeError)r s r Ú__del__z ApplicationCommunicator.__del__7 sC ð Ø II IÑ 'Ô 'Ð 'Ð 'Ð 'øÝð ð ð à DDð øøøs
(§(c óJ K | j |¦ « d{V dS )z;
Sends a single message to the application
N)r r )r Úmessages r Ú
send_inputz"ApplicationCommunicator.send_input? s7 è è ð
Ô ×"Ò" 7Ñ+Ô+Ð+Ð+Ð+Ð+Ð+Ð+Ð+Ð+Ð+r c ó2 K | j ¦ « r| j ¦ « t |¦ « 4 d{V | j ¦ « d{V cddd¦ « d{V S # 1 d{V swxY w Y dS # t j $ rw}| j ¦ « r| j ¦ « n=| j ¦ « | j d{V n# t j $ r Y nw xY w|d}~ww xY w)zX
Receives a single message from the application, with optional timeout.
N)
r r r r r r r Ú TimeoutErrorr r )r r Úes r Úreceive_outputz&ApplicationCommunicator.receive_outputF sÔ è è ð
;× Ò Ñ Ô ð !Ø K× Ò Ñ Ô Ð ð
Ý$ WÑ-Ô-ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5Ø !Ô .× 2Ò 2Ñ 4Ô 4Ð4Ð4Ð4Ð4Ð4Ð4ð
5ð
5ð
5ð
5ñ
5ô
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5ð
5øøøð
5ð
5ð
5ð
5ð
5ð
5øåÔ#ð
ð
ð
à{× Ò Ñ!Ô!ð
Ø ×"Ò"Ñ$Ô$Ð$Ð$à ×"Ò"Ñ$Ô$Ð$ðØ +Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%øÝ Ô-ð ð ð ØDðøøøàGøøøøð
øøøs` ¶B Á A=Á*B Á=
BÂB Â
BÂ B ÂDÂ A DÃ,
C:Ã9DÃ:D Ä DÄ D Ä DÄD皙¹?ç{®Gáz?c ó0 K t j ¦ « }t j ¦ « |z
|k rO| j ¦ « sdS t j |¦ « d{V t j ¦ « |z
|k °O| j ¦ « S )zO
Checks that there is no message to receive in the given time.
FN)ÚtimeÚ monotonicr Úemptyr Úsleep)r r ÚintervalÚstarts r Úreceive_nothingz'ApplicationCommunicator.receive_nothing] s è è õ
Ñ Ô ÝnÑ Ô Ñ&¨Ò0Ð0ØÔ$×*Ò*Ñ,Ô,ð
Ø uÝ- Ñ)Ô)Ð )Ð )Ð )Ð )Ð )Ð )Ð )õ nÑ Ô Ñ&¨Ò0Ð0ð Ô ×&Ò&Ñ(Ô(Ð(r N)r )T)r/ r0 ) Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r! r$ r' r* r. r8 © r r r r s ðð ð
ð
ð
ð ð ð ð ð&!ð !ð !ð !ðð ð ð,ð ,ð ,ðð ð ð ð.
)ð
)ð
)ð
)ð
)ð
)r r )r r r2 Ú
compatibilityr r r r r= r r ú<module>r? s ðØ Ø Ð Ð Ð Ø à 4Ð 4Ð 4Ð 4Ð 4Ð 4Ø -Ð -Ð -Ð -Ð -Ð -ð^)ð ^)ð ^)ð ^)ð ^)ñ ^)ô ^)ð ^)ð ^)ð ^)r