כh SrSSKJr SSKJrJrJrJr SSKJ r J r SSK J r J r JrJr \"S5r"SS\ 5r"S S \ 5r\ "S S 55rS \S\S\\4SjrS\ S\\S\4Sjrg)z Buffer byte streams. )count)DictIteratorListTypeVar)Factorydefine)AMPCommandIntegerStringTc,\rSrSrSrS\"54/rSrg) StreamOpenz Open a new stream. streamIdN)__name__ __module__ __qualname____firstlineno____doc__r response__static_attributes__r^C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/trial/_dist/stream.pyrrsgi()Hrrc<\rSrSrSrS\"54S\"54/rSrg) StreamWritez$ Write a chunk of data to a stream. rsdatarN) rrrrrr Bytes argumentsrrrrrrs$ gi %'Irrc\rSrSr%Sr\"5r\\\ S'\ "\ 5r \ \\\4\ S'S\4SjrS\S\SS 4S jrS\S\\4S jrS rg ) StreamReceiver"z1 Buffering de-multiplexing byte stream receiver. _counter_streamsreturncN[UR5n/URU'U$)z5 Open a new stream and return its unique identifier. )nextr%r&)selfnewIds ropenStreamReceiver.open+s%T]]#! e rstreamIdchunkNc@URURU5 g)zi 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 rwriteStreamReceiver.write3s h&&u-rc8URRU5$)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 rfinishStreamReceiver.finish;s}}  **rr)rrrrrrr%rint__annotations__rdictr&rrbytesr,r2r6rrrrr#r#"sr$gHhsm%'.t}Hd3U #$4c.c.%.D.+s+tE{+rr#data chunkSizer'c#j# SnU[U5:aXX!-v X!- nU[U5:aMgg7f)z 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)r<r=poss rr/r/Es9 C D /))  D /s-33ampchunksc# UR[5IShvN Sn[U[5(deUHnUR[X#S9IShvN M! U$NEN 7f)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.r<) callRemoter isinstancer8r)rArBr.oneChunks rstreamrGVs`nnZ00*=H h $ $$ $nn[8nKKK O 1 Ls!A%A!:A%A# A%#A%N)r itertoolsrtypingrrrrattrsrr twisted.protocols.ampr r r r r rrrr#r;r8r/rGrrrrLs00!HH CL**'+++D#(5/"c8E?sr