Vh dZddlmZddlmZmZmZmZddlm Z m Z ddl m Z m Z mZmZedZGdde ZGd d e Ze Gd d Zd ededeefdZde deedefdZy)z Buffer byte streams. )count)DictIteratorListTypeVar)Factorydefine)AMPCommandIntegerStringTc$eZdZdZdefgZy) StreamOpenz Open a new stream. streamIdN)__name__ __module__ __qualname____doc__r responseJ/home/dcms/DCMS/lib/python3.12/site-packages/twisted/trial/_dist/stream.pyrrsgi()Hrrc4eZdZdZdefdefgZy) StreamWritez, Write a chunk of data to a stream. rsdataN)rrrrr Bytes argumentsrrrrrs$ gi %'IrrceZdZUdZeZeeed<e e Z e ee efed<defdZdededdfd Zdede efd Zy) StreamReceiverz9 Buffering de-multiplexing byte stream receiver. _counter_streamsreturncNt|j}g|j|<|S)zE Open a new stream and return its unique identifier. )nextr r!)selfnewIds ropenzStreamReceiver.open+s%T]]#! e rstreamIdchunkNc@|j|j|y)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-rc8|jj|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"sr$gHhsm%'.t}Hd3U #$4c.c.%.D.+s+tE{+rrdata chunkSizer"c#jKd}|t|kr||||z||z }|t|kryyw)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)Es@ C D /3y)) y D /s.33ampchunkscK|jtd{d}t|tsJ|D]"}|jt||d{$|S7B7 w)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?VshnnZ00*=H h $$ $Lnn[8(nKKKL O 1 Ls!A"A9A"A  A" A"N)r itertoolsrtypingrrrrattrsrr twisted.protocols.ampr r r r rrrrrr3r0r)r?rrrrDs00!HH CL**'+++D#(5/"c8E?sr