a ތxd/ @s:ddlZddlZddlmZddlmZGdddZdS)N)guarantee_single_callable)timeoutc@sPeZdZdZddZdddZddd Zd d Zd d ZdddZ dddZ dS)ApplicationCommunicatorz} Runs an ASGI application in a test mode, allowing sending of messages to it and retrieval of messages it sends. cCsFt||_||_t|_t|_t|||jj|jj |_ dSN) r applicationscopeasyncioQueue input_queue output_queue ensure_futuregetputfuture)selfrrrG/var/www/html/Ranjet/env/lib/python3.9/site-packages/asgiref/testing.py__init__s   z ApplicationCommunicator.__init__rcszt|4IdHFz|jIdH|jWntjyBYn0WdIdHqn1IdHsd0YW|js|jz|jIdHWqtjyYq0n<|js|jz|jIdHWntjyYn00dS)zV Waits for the application to stop itself and returns any exceptions. N) async_timeoutrresultr CancelledErrordonecancel)rrrrrwaits& 2    zApplicationCommunicator.waitTcCs(|js|jn|r$|jdSr)rrrr)r exceptionsrrrstop*s  zApplicationCommunicator.stopcCs(z|jddWnty"Yn0dS)NF)r)r RuntimeError)rrrr__del__1s zApplicationCommunicator.__del__cs|j|IdHdS)z; Sends a single message to the application N)r r)rmessagerrr send_input9sz"ApplicationCommunicator.send_inputc s|jr|jzRt|4IdH(|jIdHWdIdHWS1IdHsZ0YWnptjy}zV|jr|jn0|jz|jIdHWntj yYn0|WYd}~n d}~00dS)zX Receives a single message from the application, with optional timeout. N) rrrrr rr TimeoutErrorrr)rrerrrreceive_output@s  @   z&ApplicationCommunicator.receive_output皙?{Gz?csBt}t||kr8|js&dSt|IdHq|jS)zO Checks that there is no message to receive in the given time. FN)time monotonicr emptyr sleep)rrintervalstartrrrreceive_nothingWs  z'ApplicationCommunicator.receive_nothingN)r)T)r)r$r%) __name__ __module__ __qualname____doc__rrrrr r#r,rrrrrs   r)r r& compatibilityrrrrrrrrs