+ O|j^RIHt^RIt^RIHtHt^RIHtHtH t ^RI H t H t ^RI HtHt^RIHtHt^RIHt!R R ] 4tR R ltR Rlt]t^RI HtRRltRRltR# ]d ^RIHtL>""r!cV^8dQhRR/#)rrNoner)rs"rrr (s&&t&r!c 6VPP4#r#)r&checkr$s&rr0 Frame.check(s~~##%%r!max_sizeNr c ,V^8dQhRRRRRRRRR R /#) rreaderz!Callable[[int], Awaitable[bytes]]maskrr2z int | Noner %Sequence[extensions.Extension] | Nonerrr)rs"rrr ,sCL L 1L  L  L : L  L r!c |"V!^4GRjxL p\P!RV4wrgV^,'dRMRpV^@,'dRMRp V^ ,'dRMRp V^,'dRMRp \P!V^,4p T^,'dRMRT8wd \ R4hT^,pT^~8Xd+T!^4GRjxL p\P!RT4wpM0T^8Xd*T!^4GRjxL p\P!RT4wpTeY8d \ Y4hT'dT!^4GRjxL pT!T4GRjxL pT'd \TX4p\P!YYY4pTf.p\T4FpTPTTR 7pK TP4T!TPTPTPTPTP TP"4#EL \dp \ R4T hRp ? ii;iEL^EL0LL5i) a Read a WebSocket frame. Args: reader: Coroutine that reads exactly the requested number of bytes, unless the end of file is reached. mask: Whether the frame should be masked i.e. whether the read happens on the server side. max_size: Maximum payload size in bytes. extensions: List of extensions, applied in reverse order. Raises: PayloadTooBig: If the frame exceeds ``max_size``. ProtocolError: If the frame contains incorrect values. Nz!BBTFzinvalid opcodezincorrect maskingz!Hz!Q)r2)structunpackr Opcode ValueErrorr r rrreverseddecoder0rrrrrr)clsr4r5r2r rhead1head2rrrrrexclength mask_bitsr& extensions&&$$$ rread Frame.read+s6AY}}UD1 j((dez))tuz))tuz))tu ;]]5:#56FJ&&DEd : 34 4# S=?D dD1IV s]?D dD1IV  F$51 1 $QiIF^# dI.DLLs$E  J!*-I!((X(FI.  MM    NN NN NN NN   W ; 01s : ;## ($s H<H>H<H<!H<4H<9HH<%/H<H20H<H59H< H< H8 H<H: H<(B)H< H/ H**H//H<5H<8H<:H<c(V^8dQhRRRRRRRR/#) rwritezCallable[[bytes], Any]r5rr r6rr.r)rs"rrr zs8JJ%J J : J  Jr!c JV!VPPW#R74R#)aF Write a WebSocket frame. Args: frame: Frame to write. write: Function that writes bytes. mask: Whether the frame should be masked i.e. whether the write happens on the client side. extensions: List of extensions, applied in order. Raises: ProtocolError: If the frame contains incorrect values. )r5r N)r& serialize)r%rHr5r s&&$$rrH Frame.writezs0 dnn&&D&HIr!r)__name__ __module__ __qualname____firstlineno____annotations__rrrpropertyr&r+r0 classmethodrErH__static_attributes__rr!rrrs I  OD$D$D$   #&L $ L =A L L \J =A JJr!rc V^8dQhRRRR/#)rrrrztuple[int, BytesLike]r)rs"rrrs::x:$9:r!c\V\4'd+\PPVP 43#\V\ 4'd\PPV3#\R4h)a Convert a string or byte-like object to an opcode and a bytes-like object. This function is designed for data frames. If ``data`` is a :class:`str`, return ``Opcode.TEXT`` and a :class:`bytes` object encoding ``data`` in UTF-8. If ``data`` is a bytes-like object, return ``Opcode.BINARY`` and a bytes-like object. Raises: TypeError: If ``data`` doesn't have a supported type. data must be str or bytes-like) isinstancer)r r:TEXTencoder BINARY TypeErrorrs&r prepare_datar]sZ $}}!!4;;=00 D) $ $}}##T))899r!c V^8dQhRRRR/#)rrrrbytesr)rs"rrrs::x:E:r!c\V\4'dVP4#\V\4'd \ V4#\ R4h)aI Convert a string or byte-like object to bytes. This function is designed for ping and pong frames. If ``data`` is a :class:`str`, return a :class:`bytes` object encoding ``data`` in UTF-8. If ``data`` is a bytes-like object, return a :class:`bytes` object. Raises: TypeError: If ``data`` doesn't have a supported type. rV)rWr)rYr r_r[r\s&r prepare_ctrlras@${{} D) $ $T{899r!)Closec V^8dQhRRRR/#)rrr_rztuple[int, str]r)rs"rrrs $ $e $ $r!c^\P!V4pVPVP3#)z Parse the payload from a close frame. Returns: Close code and reason. Raises: ProtocolError: If data is ill-formed. UnicodeDecodeError: If the reason isn't valid UTF-8. )rbparsecodereason)rcloses& r parse_closeris% KK E ::u|| ##r!c$V^8dQhRRRRRR/#)rrfintrgr)rr_r)rs"rrrs!++#+s+u+r!c4\W4P4#)z+ Serialize the payload for a close frame. )rbrJ)rfrgs&&rserialize_closerms   ( ( **r!) __future__rr8collections.abcrrtypingrrrr r exceptionsr r r rspeedupsr ImportErrorutilsrr]ra encode_datarbrirmrr!rrwsk" /,,!5(#% @JJ@JF:0:0  $ +[#"#sA)) A98A9