3 g/ @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||_||_tj|_tj|_tj|j||jj|jj |_ dS)N) r applicationscopeasyncioQueue input_queue output_queue ensure_futuregetputfuture)selfrrrM/var/www/tester-filtro-web/env/lib/python3.6/site-packages/asgiref/testing.py__init__s    z ApplicationCommunicator.__init__rc!szXt|4IdH8y|jIdH|jjWntjk rDYnXWdQIdHRXWd|jjs|jjy|jIdHWntjk rYnXXdS)zV Waits for the application to stop itself and returns any exceptions. N) async_timeoutrresultrCancelledErrordonecancel)rrrrrwaits   zApplicationCommunicator.waitTcCs(|jjs|jjn|r$|jjdS)N)rrrr)r exceptionsrrrstop*s  zApplicationCommunicator.stopc Cs*y|jddWntk r$YnXdS)NF)r)r RuntimeError)rrrr__del__1szApplicationCommunicator.__del__cs|jj|IdHdS)z; Sends a single message to the application N)r r)rmessagerrr send_input9sz"ApplicationCommunicator.send_inputcs|jjr|jjy2t|4IdH|jjIdHSQIdHRXWnptjk r}zR|jjrp|jjn2|jjy|jIdHWntj k rYnX|WYdd}~XnXdS)zX Receives a single message from the application, with optional timeout. N) rrrrr r r TimeoutErrorrr)rrerrrreceive_output@s      z&ApplicationCommunicator.receive_output皙?{Gz?csFtj}x2tj||kr:|jjs(dStj|IdHq W|jjS)zO Checks that there is no message to receive in the given time. FN)time monotonicr emptyrsleep)rrintervalstartrrrreceive_nothingWs  z'ApplicationCommunicator.receive_nothingN)r)T)r)r#r$) __name__ __module__ __qualname____doc__rrrrrr"r+rrrrrs   r)rr%Z compatibilityrrrrrrrrs