Files
Trancribe/venv/lib/python3.12/site-packages/websockets/__pycache__/streams.cpython-312.pyc

88 lines
5.3 KiB
Plaintext
Raw Normal View History

<EFBFBD>
$n!j<><00><01>0<00>ddlmZddlmZGd<03>d<04>Zy)<06>)<01> annotations)<01> Generatorc<01>P<00>eZdZdZd d<02>Zd d<03>Zd d<04>Zd d<05>Zdd<06>Zdd<07>Z d d<08>Z
d d <09>Z y
)<10> StreamReaderz<72>
Generator-based stream reader.
This class doesn't support concurrent calls to :meth:`read_line`,
:meth:`read_exact`, or :meth:`read_to_eof`. Make sure calls are
serialized.
c<01>0<00>t<00>|_d|_y)NF)<03> bytearray<61>buffer<65>eof<6F><01>selfs <20>T/home/jean/linux-transcriber/venv/lib/python3.12/site-packages/websockets/streams.py<70>__init__zStreamReader.__init__s<00><00><1F>k<EFBFBD><04> <0B><18><04><08>c#<01>dK<00>d}d} |jjd|<03>dz}|dkDrnLt|j<00>}||kDrtd|<03>d|<01>d<06><05><00>|jrt d|<03>d<08><03><00>d <09><01><00>q||kDrtd|<02>d|<01>d<06><05><00>|jd |}|jd |<02>=|S<00>w)
a<EFBFBD>
Read a LF-terminated line from the stream.
This is a generator-based coroutine.
The return value includes the LF character.
Args:
m: Maximum number bytes to read; this is a security limit.
Raises:
EOFError: If the stream ends without a LF.
RuntimeError: If the stream ends in more than ``m`` bytes.
r<00>
<EFBFBD><00>read <20> bytes, expected no more than <20> bytes<65>stream ends after z bytes, before end of lineN)r <00>find<6E>len<65> RuntimeErrorr
<00>EOFError)r <00>m<>n<>p<>rs r <00> read_linezStreamReader.read_lines<><00><00><><00> <0E><01> <0A><01><12><14> <0B> <0B> <20> <20><15><01>*<2A>Q<EFBFBD>.<2E>A<EFBFBD><10>1<EFBFBD>u<EFBFBD><15><13>D<EFBFBD>K<EFBFBD>K<EFBFBD> <20>A<EFBFBD><10>1<EFBFBD>u<EFBFBD>"<22>U<EFBFBD>1<EFBFBD>#<23>-K<>A<EFBFBD>3<EFBFBD>f<EFBFBD>#U<>V<>V<><13>x<EFBFBD>x<EFBFBD><1E>!3<>A<EFBFBD>3<EFBFBD>6P<36>Q<>R<>R<> <11><13> <0A>q<EFBFBD>5<EFBFBD><1E><15>q<EFBFBD>c<EFBFBD>)G<><01>s<EFBFBD>&<26>Q<>R<> R<> <10>K<EFBFBD>K<EFBFBD><02><11>O<EFBFBD><01> <10>K<EFBFBD>K<EFBFBD><02><11><02>O<EFBFBD><10><08>s<00>B.B0c#<01>(K<00>|dk\sJ<00>t|j<00>|krP|jr't|j<00>}td|<02>d|<01>d<04><05><00>d<05><01>t|j<00>|kr<01>P|jd|}|jd|<01>=|S<00>w)z<>
Read a given number of bytes from the stream.
This is a generator-based coroutine.
Args:
n: How many bytes to read.
Raises:
EOFError: If the stream ends in less than ``n`` bytes.
rrz bytes, expected rN)rr r
r)r rrrs r <00>
read_exactzStreamReader.read_exact6s<><00><00><><00><11>A<EFBFBD>v<EFBFBD> <0A>v<EFBFBD><11>$<24>+<2B>+<2B><1E><11>"<22><13>x<EFBFBD>x<EFBFBD><17><04> <0B> <0B>$<24><01><1E>!3<>A<EFBFBD>3<EFBFBD>6G<36><01>s<EFBFBD>&<26>Q<>R<>R<> <11> <12>$<24>+<2B>+<2B><1E><11>"<22>
<11>K<EFBFBD>K<EFBFBD><02><11>O<EFBFBD><01> <10>K<EFBFBD>K<EFBFBD><02><11><02>O<EFBFBD><10><08>s <00>A/B<01>2 Bc#<01><>K<00>|js=t|j<00>}||kDrtd|<02>d|<01>d<03><05><00>d<04><01>|js<01>=|jdd}|jdd<04>=|S<00>w)a
Read all bytes from the stream.
This is a generator-based coroutine.
Args:
m: Maximum number bytes to read; this is a security limit.
Raises:
RuntimeError: If the stream ends in more than ``m`` bytes.
rrrN)r
rr r)r rrrs r <00> read_to_eofzStreamReader.read_to_eofMsj<00><00><><00><17>(<28>(<28><13>D<EFBFBD>K<EFBFBD>K<EFBFBD> <20>A<EFBFBD><10>1<EFBFBD>u<EFBFBD>"<22>U<EFBFBD>1<EFBFBD>#<23>-K<>A<EFBFBD>3<EFBFBD>f<EFBFBD>#U<>V<>V<> <11> <17>(<28>(<28>
<11>K<EFBFBD>K<EFBFBD><01>N<EFBFBD><01> <10>K<EFBFBD>K<EFBFBD><01>N<EFBFBD><10><08>s <00>A A,<01> A,c#<01>JK<00> |jry|jryd<03><01><00><1F>w)zy
Tell whether the stream has ended and all data was read.
This is a generator-based coroutine.
TFN)r r
r s r <00>at_eofzStreamReader.at_eofcs)<00><00><><00><13><13>{<7B>{<7B><1C><13>x<EFBFBD>x<EFBFBD><1B> <12><13>s<00>!#c<01>\<00>|jr td<01><00>|xj|z c_y)z<>
Write data to the stream.
:meth:`feed_data` cannot be called after :meth:`feed_eof`.
Args:
data: Data to write.
Raises:
EOFError: If the stream has ended.
<20> stream endedN)r
rr )r <00>datas r <00> feed_datazStreamReader.feed_datass$<00><00> <10>8<EFBFBD>8<EFBFBD><1A>><3E>*<2A> *<2A> <0C> <0B> <0B>t<EFBFBD><1B> rc<01>@<00>|jr td<01><00>d|_y)z<>
End the stream.
:meth:`feed_eof` cannot be called more than once.
Raises:
EOFError: If the stream has ended.
r'TN)r
rr s r <00>feed_eofzStreamReader.feed_eof<6F>s<00><00> <10>8<EFBFBD>8<EFBFBD><1A>><3E>*<2A> *<2A><17><04>rc<01>"<00>|jdd<01>=y)zG
Discard all buffered data, but don't end the stream.
N)r r s r <00>discardzStreamReader.discard<72>s<00><00>
<11>K<EFBFBD>K<EFBFBD><01>NrN)<02>return<72>None)r<00>intr.<00> Generator[None, None, bytearray])rr0r.r1)r.zGenerator[None, None, bool])r(zbytes | bytearrayr.r/) <0C>__name__<5F>
__module__<EFBFBD> __qualname__<5F>__doc__rrr!r#r%r)r+r-<00>rr rrs0<00><00><08><19> <11>D<11>.<11>,<12> <1C>" <18>rrN)<05>
__future__r<00>collections.abcrrr6rr <00><module>r9s<00><01>"<22>%<25>Q<1B>Qr