"j ldZddlZddlmZdZej eZGddZGddZ y) 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)utilreStructuredTextc,eZdZdZddZddZdZdZy) FileLikeQueueaA 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 cTd|_tj||_d|_y)NF) is_closedqueueQueueunread)selfmax_sizes C/srv/dav/.venv/lib/python3.12/site-packages/wsgidav/stream_tools.py__init__zFileLikeQueue.__init__2s [[*  rc|j}d|_|dk(s|dks|dkDrNt||kr@ ||jjddz }|dk(r&|dkr,|dkDrt||kr@|dkDrt||kDr||d|_|d|}t |tusJ|S#tj$r|j rYXYzwxYw)aRead 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. rrTg?N)r lenr getEmptyr typebytes)r sizeress rreadzFileLikeQueue.read7skk SjD1Hc#ho tzz~~dC00 SjD1Hc#ho !8C4de*DKet*CCyE!!! ;; >>" sB((C  C ct|tusJ|jr tdt j |r|j j|y|D]}|j j|y)zxPut 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)r chunkos rwritezFileLikeQueue.writeUsh E{e### >><= =   e $ JJNN5 ! " q! "rcd|_y)NT)r )r s rclosezFileLikeQueue.closees rN)r)__name__ __module__ __qualname____doc__rrr r"rrrr!s  <" rrceZdZdZdZddZy) StreamingFilez7A file object wrapped around an iterator / data stream.c ||_d|_y)z+Initialise the object with the data stream.N) data_streambuffer)r r,s rrzStreamingFile.__init__s& rNc>|t|j|krE |xjt|jz c_|,t|j|krE|jd|}| d|_|S|j|d|_|S#t$rY;wxYw)zRead bytes from an iterator.Nr+)rr-nextr, StopIteration)r r sized_chunks rrzStreamingFile.readslc$++.5  tD$4$455 lc$++.5 kk%4( <DK++de,DK!  s(B BB)N)r#r$r%r&rrr'rrr)r)sA rr)) r&r wsgidavr __docformat__get_module_loggerr#_loggerrr)r'rrr6s@  " $  *FF|r