+ Dfj Rt^RIHt^RIHtHtHtHt^RIH t H t ^RI H t H t HtHt]!R4t!RR] 4t!RR ] 4t] !R R 44tR R ltRRltR#)z Buffer byte streams. )count)DictIteratorListTypeVar)Factorydefine)AMPCommandIntegerStringTc.]tRt^tRtR]!43.tRtR#) StreamOpenz Open a new stream. streamIdN)__name__ __module__ __qualname____firstlineno____doc__r response__static_attributes__r]tRt^tRtR]!43R]!43.tRtR#) StreamWritez$ Write a chunk of data to a stream. rsdatarN) rrrrrr Bytes argumentsrrrrrrs$ gi %'Irrca]tRt^"toRt]!4t]!]4t V3RlRlt V3RlRlt V3RlRlt V3Rlt R tVtR #) StreamReceiverz1 Buffering de-multiplexing byte stream receiver. c <V^8dQhRS[/#)return)int)format __classdict__s"r __annotate__StreamReceiver.__annotate__+scrc N\VP4p.VPV&V#)z5 Open a new stream and return its unique identifier. )next_counter_streams)selfnewIds& ropenStreamReceiver.open+s%T]]#! e rc*<V^8dQhRS[RS[RR/#)r"streamIdchunkr#N)r$bytes)r%r&s"rr'r(3s"..c.%.D.rc JVPV,PV4R#)zi Write to an open stream using its unique identifier. @raise KeyError: If there is no such open stream. N)r,append)r-r2r3s&&&rwriteStreamReceiver.write3s h&&u-rc6<V^8dQhRS[RS[S[,/#)r"r2r#)r$rr4)r%r&s"rr'r(;s++s+tE{+rc 8VPPV4#)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-r2s&&rfinishStreamReceiver.finish;s}}  **rch<V^8dQh/S[S[,;R&S[S[S[S[,3,;R&#)r"r+r,)rr$rrr4)r%r&s"rr'r("s1 sm% 3U #$4rrN)rrrrrrr+rdictr,r/r7r<__annotate_func__r__classdictcell__)r&s@rr r "sA$gH'.t}H..++3rr cRV^8dQhR\R\R\\,/#)r"data chunkSizer#)r4r$r)r%s"rr'r'Es%#(5/rc#^"^pV\V48dWW!,xW!, pK&R#5i)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. N)len)rCrDposs&& rr3r3Es1 C D /))  s+-cRV^8dQhR\R\\,R\/#)r"ampchunksr#)r rr4r$)r%s"rr'r'Vs%c8E?src"VP\4GRjxL R,p\V\4'gQhVF"pVP\W#R7GRjxL K$ V#LML 5i)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. Nr2)r2rC) callRemoter isinstancer$r)rIrJr2oneChunks&& rstreamrOVs`nnZ00*=H h $ $$ $nn[8nKKK O 1 Ls"A-A)AA-A+ A-+A-N)r itertoolsrtypingrrrrattrsrrtwisted.protocols.ampr r r r rr rrr r3rOrrrrTsc00!HH CL**'+++D"r