tf dZddlmZddlmZmZmZmZddlm Z m Z ddl m Z m Z mZmZedZGdde ZGd d e Ze Gd d Zd ededeefdZde deedefdZdS)z Buffer byte streams. )count)DictIteratorListTypeVar)Factorydefine)AMPCommandIntegerStringTc,eZdZdZdefgZdS) StreamOpenz Open a new stream. streamIdN)__name__ __module__ __qualname____doc__r responseY/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/trial/_dist/stream.pyrrs-ggii()HHHrrcBeZdZdZdefdefgZdS) StreamWritez, Write a chunk of data to a stream. rsdataN)rrrrr Bytes argumentsrrrrrs= ggii %%''IIIrrceZdZUdZeZeeed<e e Z e ee efed<defdZdededdfd Zdede efd ZdS) StreamReceiverz9 Buffering de-multiplexing byte stream receiver. _counter_streamsreturncBt|j}g|j|<|S)zE Open a new stream and return its unique identifier. )nextr r!)selfnewIds ropenzStreamReceiver.open+s$T]##! e rstreamIdchunkNcF|j||dS)z Write to an open stream using its unique identifier. @raise KeyError: If there is no such open stream. N)r!append)r%r(r)s rwritezStreamReceiver.write3s% h&&u-----rc6|j|S)z Indicate an open stream may receive no further data and return all of its current contents. @raise KeyError: If there is no such open stream. )r!pop)r%r(s rfinishzStreamReceiver.finish;s}  ***r)rrrrrr rint__annotations__rdictr!rrbytesr'r,r/rrrrr"s$eggHhsm%%%'.wt}}Hd3U #$444c.c.%.D....+s+tE{++++++rrdata chunkSizer"c#Kd}|t|kr)||||zV||z }|t|k'dSdS)a Break a byte string into pieces of no more than ``chunkSize`` length. @param data: The byte string. @param chunkSize: The maximum length of the resulting pieces. All pieces except possibly the last will be this length. @return: The pieces. rN)len)r4r5poss rr)r)EsY C D //3y()))) y D //////rampchunkscK|td{Vd}t|tsJ|D]%}|t||d{V&|S)z Send the given stream chunks, one by one, over the given connection. The chunks are sent using L{StreamWrite} over a stream opened using L{StreamOpen}. @return: The identifier of the stream over which the chunks were sent. Nr()r(r4) callRemoter isinstancer0r)r9r:r(oneChunks rstreamr?VsnnZ00000000*=H h $ $$$$LLnn[8(nKKKKKKKKKK OrN)r itertoolsrtypingrrrrattrsrr twisted.protocols.ampr r r r rrrrrr3r0r)r?rrrrDs}000000000000!!!!!!!!HHHHHHHHHHHH GCLL********'++++++++D#(5/"c8E?sr