qi lSrSSKrSSKJr Sr\R "\5r"SS5r"SS5r g) a Implement the FileLikeQueue helper class. This helper class is intended to handle use cases where an incoming PUT request should be directly streamed to a remote target. Usage: return an instance of this class to`begin_write` and pass it to the consumer at the same time:: def begin_write(self, contentType=None): queue = FileLikeQueue(max_size=1) requests.post(..., data=queue) return queue N)utilreStructuredTextc8\rSrSrSrS SjrS SjrSrSrSr g) FileLikeQueue aA queue for chunks that behaves like a file-like. read() and write() are typically called from different threads. This helper class is intended to handle use cases where an incoming PUT request should be directly streamed to a remote target: def begin_write(self, contentType=None): # Create a proxy buffer queue = FileLikeQueue(max_size=1) # ... and use it as source for the consumer: requests.post(..., data=queue) # pass it to the PUT handler as target return queue cVSUl[R"U5UlSUlg)NF) is_closedqueueQueueunread)selfmax_sizes I/home/kali/flask_env/lib/python3.13/site-packages/wsgidav/stream_tools.py__init__FileLikeQueue.__init__1s [[*  r cURnSUlUS:XdUS:dUS:aU[U5U:aFX RRSS5- nUS:XaM'US:aM/US:a[U5U:aMFUS:a[U5U:aX!SUlUSUn[ U5[LdeU$![Ra UR (aMaNf=f)aaRead a chunk of bytes from queue. size = 0: Read next chunk (arbitrary length) > 0: Read one chunk of `size` bytes (or less if stream was closed) < 0: Read all bytes as single chunk (i.e. blocks until stream is closed) This method blocks until the requested size become available. However, if close() was called, '' is returned immediately. r rTg?N)r lenr getEmptyr typebytes)rsizeress rreadFileLikeQueue.read6skk SjD1Hc#ho zz~~dC00 SjD1Hc#ho !8C4e*DKet*CCyE!!! ;; >>" sB44%CCc[U5[LdeUR(a [S5e[R "U5(aUR RU5 gUHnUR RU5 M g)zhPut a chunk of bytes (or an iterable) to the queue. May block if max_size number of chunks is reached. zCannot write to closed objectN)rrr ValueErrorr is_basestringr put)rchunkos rwriteFileLikeQueue.writeTsf E{e### >><= =   e $ $ JJNN5 ! q!r cSUlg)NT)r )rs rcloseFileLikeQueue.closeds r )r r r N)r) __name__ __module__ __qualname____firstlineno____doc__rrr#r&__static_attributes__r rrr s  <" r rc(\rSrSrSrSrSSjrSrg) StreamingFile~z7A file object wrapped around an iterator / data stream.cXlSUlg)z+Initialise the object with the data stream.N) data_streambuffer)rr4s rrStreamingFile.__init__s& r NcPUb[UR5U:aIU=R[UR5- slUcM.[UR5U:aMIURSUnUc SUlU$URUSUlU$![a M>f=f)zRead bytes from an iterator.Nr3)rr5nextr4 StopIteration)rr sized_chunks rrStreamingFile.readslc$++.5  tD$4$455 lc$++.5 kk%4( <DK++de,DK!  s(B B%$B%)r5r4)N)r(r)r*r+r,rrr-r.r rr0r0~sA r r0) r,r wsgidavr __docformat__get_module_loggerr(_loggerrr0r.r rr@s> "   *FF|r