hBSSKrSSKJrJrJrJrJr Sr"SS\5r "SS\\ 5r "SS \\ 5r "S S \\ 5r "S S \\ 5r "SS\\ 5rg)N)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageSnappyMixinPerMessageSnappyOfferPerMessageSnappyOfferAcceptPerMessageSnappyResponsePerMessageSnappyResponseAcceptPerMessageSnappyc\rSrSrSrSrSrg)r-z! Mixin class for this extension. zpermessage-snappyN)__name__ __module__ __qualname____firstlineno____doc__EXTENSION_NAME__static_attributes__rfC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/websocket/compress_snappy.pyrr-s)NrrcH\rSrSrSr\S5rS SjrSrSr Sr Sr g ) r 8zj Set of extension parameters for `permessage-snappy` WebSocket extension offered by a client to a server. c SnSnUHn[X5S:a[SU<SUR<S35eXSnUS:Xa+USLa"[S U<S U<S UR<S35eSnMjUS :Xa+USLa"[S U<S U<S UR<S35eSnM[S U<SUR<S35e U"UU5nU$)a- Parses a WebSocket extension offer for `permessage-snappy` provided by a client to a server. :param params: Output from :func:`autobahn.websocket.WebSocketProtocol._parseExtensionsHeader`. :type params: list :returns: A new instance of :class:`autobahn.compress.PerMessageSnappyOffer`. :rtype: obj F,multiple occurrence of extension parameter '' for extension ''rclient_no_context_takeoverT#illegal extension parameter value '' for parameter '' of extension 'server_no_context_takeoverillegal extension parameter 'len Exceptionr)clsparamsaccept_no_context_takeoverrequest_no_context_takeoverpvaloffers rparsePerMessageSnappyOffer.parse>s &+"&+#A69~!hiknk}k} ~)A,C00d?#uxz{~A~P~P%QRR15.22d?#uxz{~A~P~P%QRR26/ YZ\_\n\n opp-0./1 rc[U5[:wa[S[U5-5eXl[U5[:wa[S[U5-5eX lg)a :param accept_no_context_takeover: Iff true, client accepts "no context takeover" feature. :type accept_no_context_takeover: bool :param request_no_context_takeover: Iff true, client request "no context takeover" feature. :type request_no_context_takeover: bool z.invalid type %s for accept_no_context_takeover/invalid type %s for request_no_context_takeoverN)typeboolr)r,r-)selfr,r-s r__init__PerMessageSnappyOffer.__init__js[ * +t 3LtTnOoop p*D' + , 4MPTUpPqqr r+F(rcvURnUR(aUS- nUR(aUS- nU$) Returns the WebSocket extension configuration string as sent to the server. :returns: PMCE configuration string. :rtype: str ; client_no_context_takeover; server_no_context_takeoverrr,r-r7 pmce_strings rget_extension_string*PerMessageSnappyOffer.get_extension_string~s=))  * * 9 9K  + + 9 9KrcJURURURS.$)n Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict ) extensionr,r-r>r7s r__json__PerMessageSnappyOffer.__json__s+"00.2.M.M/3/O/OQ Qrc@SUR<SUR<S3$) Returns Python object representation that can be eval'ed to reconstruct the object. :returns: Python string representation. :rtype: str z3PerMessageSnappyOffer(accept_no_context_takeover = , request_no_context_takeover = )r,r-rFs r__repr__PerMessageSnappyOffer.__repr__s8nrnMnMOSOoOop prrMN)TF) rrrrr classmethodr1r8rArGrNrrrrr r 8s; ))X-1-2G(  Qprr c8\rSrSrSrS SjrSrSrSrSr g) r z` Set of parameters with which to accept an `permessage-snappy` offer from a client by a server. Nc[U[5(d[S[U5-5eXl[U5[ :wa[S[U5-5eU(aUR (d[SU-5eX lUbP[U5[ :wa[S[U5-5eUR(aU(d[SU-5eX0lg)a :param offer: The offer being accepted. :type offer: Instance of :class:`autobahn.compress.PerMessageSnappyOffer`. :param request_no_context_takeover: Iff true, server request "no context takeover" feature. :type request_no_context_takeover: bool :param no_context_takeover: Override server ("server-to-client direction") context takeover (this must be compatible with offer). :type no_context_takeover: bool zinvalid type %s for offerr4zPinvalid value %s for request_no_context_takeover - feature unsupported by clientN'invalid type %s for no_context_takeoverzCinvalid value %s for no_context_takeover - client requested feature) isinstancer r)r5r0r6r,r-no_context_takeover)r7r0r-rVs rr8$PerMessageSnappyOfferAccept.__init__s%!6777$u+EF F + , 4MPTUpPqqr r &u/O/OnrMMN N+F(  *'(D0 IDQdLe eff009L eh{ {||#6 rcURnURR(aUS- nUR(aUS- nU$)r;r=r<)rr0r-r?s rrA0PerMessageSnappyOfferAccept.get_extension_stringsA)) :: 1 1 9 9K  + + 9 9Krc|URURR5URURS.$)rD)rEr0r-rV)rr0rGr-rVrFs rrG$PerMessageSnappyOfferAccept.__json__s;"00,,./3/O/O'+'?'?A ArcxSURR5<SUR<SUR<S3$)rJzPerMessageSnappyAccept(offer = rK, no_context_takeover = rL)r0rNr-rVrFs rrN$PerMessageSnappyOfferAccept.__repr__sZtxs}s}tGtGtIKOKkKkmqmEmEF FrrVr0r-)FN) rrrrrr8rArGrNrrrrr r s&.3%)!7F  AFrr c:\rSrSrSr\S5rSrSrSr Sr g) r z@ Set of parameters for `permessage-snappy` responded by server. c SnSnUHn[X5S:a[SU<SUR<S35eXSnUS:Xa+USLa"[S U<S U<S UR<S35eSnMjUS :Xa+USLa"[S U<S U<S UR<S35eSnM[S U<SUR<S35e U"UU5nU$)a3 Parses a WebSocket extension response for `permessage-snappy` provided by a server to a client. :param params: Output from :func:`autobahn.websocket.WebSocketProtocol._parseExtensionsHeader`. :type params: list :returns: A new instance of :class:`autobahn.compress.PerMessageSnappyResponse`. :rtype: obj Frrrr rr!Tr"r#r$r%r&r')r*r+r!r%r.r/responses rr1PerMessageSnappyResponse.parses&+"%*"A69~!hiknk}k} ~)A,C00d?#uxz{~A~P~P%QRR15.22d?#uxz{~A~P~P%QRR15. YZ\_\n\n opp-0113rcXlX lgNr!r%)r7r!r%s rr8!PerMessageSnappyResponse.__init__s+E'*D'rcJURURURS.$)rD)rEr!r%)rr!r%rFs rrG!PerMessageSnappyResponse.__json__#s+"00.2.M.M.2.M.MO Orc@SUR<SUR<S3$)rJz6PerMessageSnappyResponse(client_no_context_takeover = , server_no_context_takeover = rLrgrFs rrN!PerMessageSnappyResponse.__repr__.s8ptpOpOQUQpQpq qrrgN) rrrrrrPr1r8rGrNrrrrr r s.''RE Oqrr c0\rSrSrSrSSjrSrSrSrg) r i8zc Set of parameters with which to accept an `permessage-snappy` response from a server by a client. Nc[U[5(d[S[U5-5eXlUbP[U5[ :wa[S[U5-5eUR (aU(d[SU-5eX lg)a& :param response: The response being accepted. :type response: Instance of :class:`autobahn.compress.PerMessageSnappyResponse`. :param no_context_takeover: Override client ("client-to-server direction") context takeover (this must be compatible with response). :type no_context_takeover: bool zinvalid type %s for responseNrTzCinvalid value %s for no_context_takeover - server requested feature)rUr r)r5rcr6r!rV)r7rcrVs rr8'PerMessageSnappyResponseAccept.__init__>s{($<==:T(^KL L  *'(D0 IDQdLe eff22;N eh{ {||#6 rcfURURR5URS.$)rD)rErcrV)rrcrGrVrFs rrG'PerMessageSnappyResponseAccept.__json__Vs2"00 MM224'+'?'?A Arc\SURR5<SUR<S3$)rJz*PerMessageSnappyResponseAccept(response = r]rL)rcrNrVrFs rrN'PerMessageSnappyResponseAccept.__repr__as5]a\i\i\r\r\tvzwOwOP Pr)rVrcrf) rrrrrr8rGrNrrrrr r 8s&*70 APrr cn\rSrSrSr\S5r\S5rSrSr Sr Sr S r S r S rS rS rSrg)r ikz4 `permessage-snappy` WebSocket extension processor. cU"UURRURbUR5nU$URR5nU$rf)rcr%rVr!r* is_serveracceptpmces rcreate_from_response_accept,PerMessageSnappy.create_from_response_acceptpsa9??==171K1K1W6--I ^d]l]l^H^HI rcU"UURb UROURRUR5nU$rfr_rws rcreate_from_offer_accept)PerMessageSnappy.create_from_offer_acceptwsI9171K1K1W6--]c]i]i^F^F557 rcDXlX lX0lSUlSUlgrf) _is_serverr%r! _compressor _decompressor)r7rxr%r!s rr8PerMessageSnappy.__init__~s%$*D'*D'!rcJURURURS.$)N)rEr%r!)rr%r!rFs rrGPerMessageSnappy.__json__s)!00.2.M.M.2.M.MO Orc\SUR<SUR<SUR<S3$)NzPerMessageSnappy(is_server = rlz, client_no_context_takeover = rL)rr%r!rFs rrNPerMessageSnappy.__repr__sIw{xGxGIMIhIhjnjIjIJ Jrc UR(a:URbUR(a[R"5UlggURbUR (a[R"5Ulggrf)rrr%snappyStreamCompressorr!rFs rstart_compress_message'PerMessageSnappy.start_compress_messagesa ??'4+J+J#)#:#:#< ,K'4+J+J#)#:#:#< ,Krc8URRU5$rf)r add_chunkr7datas rcompress_message_data&PerMessageSnappy.compress_message_datas))$//rcg)NrrrFs rend_compress_message%PerMessageSnappy.end_compress_messagesrc UR(a:URbUR(a[R"5UlggURbUR (a[R"5Ulggrf)rrr!rStreamDecompressorr%rFs rstart_decompress_message)PerMessageSnappy.start_decompress_messagesa ??!!)T-L-L%+%>%>%@".M!!)T-L-L%+%>%>%@".Mrc8URRU5$rf)r decompressrs rdecompress_message_data(PerMessageSnappy.decompress_message_datas!!,,T22rcgrfrrFs rend_decompress_message'PerMessageSnappy.end_decompress_messages r)rrrr!r%N)rrrrrrPr{r~r8rGrNrrrrrrrrrrr r ks_  "O J=0A3 rr )r autobahn.websocket.compress_baserrrrr__all__objectrr r r r r rrrrs6  Ffp35JfpRJF"?AVJFZGq9;PGqT0P%EG\0Pf@ )+@@ r