?h\ >SSKJr SSKJr SSKJr "SS\5rg)) AsyncConsumer)aclose_old_connections) StopConsumercZ\rSrSrSrSrSSS.SjrSS .S jrS rS r S r Sr Sr Sr g)AsyncHttpConsumerzZ Async HTTP consumer. Provides basic primitives for building asynchronous HTTP endpoints. c/Ulg)Nbody)selfargskwargss YC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\channels/generic/http.py__init__AsyncHttpConsumer.__init__ s  N)statusheadersc# Uc/nO.[U[5(a[UR55nUR SXS.5IShvN gN7f)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)r rrs r send_headersAsyncHttpConsumer.send_headerssL ?G  & &7==?+Gii*f Q   sA AAAF) more_bodyc# [U[5(dS5eURSXS.5IShvN gN7f)z 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)rr r N)rbytesr)r r r s r send_bodyAsyncHttpConsumer.send_body"s>$&&;(;;&ii)4 P   s 4><>c~# UR"SSU0UD6IShvN URU5IShvN gNN7f)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#)r rr rs r send_responseAsyncHttpConsumer.send_response/s= 8v8888nnT""" 9"s=9=;==c # [S5e7f)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.)NotImplementedError)r r s rhandleAsyncHttpConsumer.handle8s " M  s c # g7f)zP Overrideable place to run disconnect handling. Do not send anything from here. Nr&)r s r disconnectAsyncHttpConsumer.disconnectBs scn# SU;aURRUS5 URS5(dUURSR UR55IShvN UR 5IShvN [ 5egN'N!UR 5IShvN f=f7f)z Async entrypoint - concatenates body fragments and hands off control to ``self.handle`` when the body has been completely received. r r rN)r appendgetr+joinr.rr messages r http_requestAsyncHttpConsumer.http_requestIs W  II  WV_ -{{;'' (kk#((499"5666oo'''. (6'doo'''sL;B5-B+B,B0B5BB5BB5B2+B.,B22B5cz# UR5IShvN [5IShvN [5eN N7f)z7 Let the user do their cleanup and close the consumer. N)r.rrr4s rhttp_disconnect!AsyncHttpConsumer.http_disconnectWs3oo$&&&n &s;7;9;;r )__name__ __module__ __qualname____firstlineno____doc__rrr#r'r+r.r6r9__static_attributes__r&rrrrs; ,/ $27  #   !rrN)channels.consumerrdbr exceptionsrrr&rrrDs+'%V Vr