U 9j\ @s8ddlmZddlmZddlmZGdddeZdS)) AsyncConsumer)aclose_old_connections) StopConsumerc@s^eZdZdZddZdddddZd d d d Zd dZddZddZ ddZ ddZ dS)AsyncHttpConsumerzf Async HTTP consumer. Provides basic primitives for building asynchronous HTTP endpoints. cOs g|_dS)N)body)selfargskwargsr 9/tmp/pip-unpacked-wheel-o8d015gg/channels/generic/http.py__init__ szAsyncHttpConsumer.__init__N)statusheaderscs@|dkrg}nt|tr$t|}|d||dIdHdS)a? Sets the HTTP response status and headers. Headers may be provided as a list of tuples or as a dictionary. Note that the ASGI spec requires that the protocol server only starts sending the response to the client after ``self.send_body`` has been called the first time. Nzhttp.response.start)typerr) isinstancedictlistitemssend)rrrr r r send_headerss    zAsyncHttpConsumer.send_headersF) more_bodycs.t|tstd|d||dIdHdS)a Sends a response body to the client. The method expects a bytestring. Set ``more_body=True`` if you want to send more body content later. The default behavior closes the response, and further messages on the channel will be ignored. zBody is not byteszhttp.response.body)rrrN)rbytesAssertionErrorr)rrrr r r send_body"s zAsyncHttpConsumer.send_bodycs.|jfd|i|IdH||IdHdS)z Sends a response to the client. This is a thin wrapper over ``self.send_headers`` and ``self.send_body``, and everything said above applies here as well. This method may only be called once. rN)rr)rrrr r r r send_response/szAsyncHttpConsumer.send_responsecs tddS)z Receives the request body as a bytestring. Response may be composed using the ``self.send*`` methods; the return value of this method is thrown away. z?Subclasses of AsyncHttpConsumer must provide a handle() method.N)NotImplementedError)rrr r r handle8szAsyncHttpConsumer.handlecsdS)zh Overrideable place to run disconnect handling. Do not send anything from here. Nr )rr r r disconnectBszAsyncHttpConsumer.disconnectcsZd|kr|j|d|dsVz|d|jIdHW5|IdHXtdS)z Async entrypoint - concatenates body fragments and hands off control to ``self.handle`` when the body has been completely received. rrN)rappendgetrrjoinrrmessager r r http_requestIs zAsyncHttpConsumer.http_requestcs$|IdHtIdHtdS)zG Let the user do their cleanup and close the consumer. N)rrrr$r r r http_disconnectWs z!AsyncHttpConsumer.http_disconnect) __name__ __module__ __qualname____doc__r rrrrrr&r'r r r r rs   rN)Zchannels.consumerrdbr exceptionsrrr r r r s