Yj!ddlmZddlZddlZddlmZmZmZmZm Z m Z ddl m Z ddlmZddlmZddlmZmZdd lmZdd lmZmZmZmZmZmZdd lmZm Z d gZ!Gd d eeZ"GddeZ#GddeZ$GddeeZ% ddZ&ddZ' ddZ(ddZ)d dZ*d!dZ+ d" d#dZ, d$ d%dZ-y)&) annotationsN)AsyncGenerator AsyncIterable AsyncIteratorIterableIteratorMapping)dumps)Any) urlencode) StreamClosedStreamConsumed)MultipartStream)AsyncByteStreamRequestContent RequestData RequestFilesResponseContentSyncByteStream)peek_filelike_lengthprimitive_value_to_str ByteStreamc$eZdZddZddZddZy)rc||_yN_streamselfstreams N/var/www/html/vmm-quimica/venv/lib/python3.12/site-packages/httpx2/_content.py__init__zByteStream.__init__s  c#(K|jywrrr s r"__iter__zByteStream.__iter__sllsc*K|jywrrr&s r" __aiter__zByteStream.__aiter__"sllsN)r!bytesreturnNoner+zIterator[bytes]r+zAsyncIterator[bytes])__name__ __module__ __qualname__r#r'r)r$r"rrsr$c eZdZdZddZddZy)IteratorByteStreamcT||_d|_tj||_yNF)r_is_stream_consumedinspect isgenerator _is_generatorrs r"r#zIteratorByteStream.__init__)s$ #( $008r$c#`K|jr|jr td|_t|jdrU|jj |j }|r-||jj |j }|r,yy|jEd{y7w)NTread)r8r;rhasattrrr= CHUNK_SIZE)r chunks r"r'zIteratorByteStream.__iter__.s  # #(:(: " "#' 4<< (LL%%doo6E  ))$//: || # #sBB.B.&B,'B.N)r!zIterable[bytes]r+r,r-)r/r0r1r?r#r'r2r$r"r4r4&sJ9 $r$r4c eZdZdZddZddZy)AsyncIteratorByteStreamr5cT||_d|_tj||_yr7)rr8r9 isasyncgenr;rs r"r#z AsyncIteratorByteStream.__init__As$ #( $//7r$cpK|jr|jr td|_t|jdrf|jj |j d{}|r6||jj |j d{}|r5yy|jj} |23d{}|7i7776 t|tr|jd{7yy#t|tr|jd{7wwxYww)NTaread) r8r;rr>rrFr?r) isinstanceraclose)r r@r!parts r"r)z!AsyncIteratorByteStream.__aiter__Fs  # #(:(: " "#' 4<< ),,,,T__==E "ll00AA \\++-F *"($J>B &fn5 --/))6:fn5 --/))6sA(D6*C+3D6CD6&D6DC C C DD6D6CD#D6?DD6$D3+D.,D33D6N)r!zAsyncIterable[bytes]r+r,r.)r/r0r1r?r#r)r2r$r"rBrB>sJ8 *r$rBc eZdZdZddZddZy)UnattachedStreamz If a request or response is serialized using pickle, then it is no longer attached to a stream for I/O purposes. Any stream operations should result in `httpx2.StreamClosed`. ctrrr&s r"r'zUnattachedStream.__iter__ds nr$cKtwrrMr&s r"r)zUnattachedStream.__aiter__gsns Nr-r.)r/r0r1__doc__r'r)r2r$r"rKrK]s r$rKct|ttfrLt|tr|jdn|}t |}|r dt|ini}|t |fSt|t r ! )*I6G'-C)DEG*7333 G] +& 2/888 5d7m5FG HHr$c g}|jD]b\}}t|ttfr+|j |Dcgc]}|t |fc}G|j |t |fdt|djd}tt|}d}||d}|t|fScc}w)NT)doseqrQz!application/x-www-form-urlencodedrRz Content-Type) itemsrGlisttupleextendrappendr rUrTrVr) data plain_datakeyvalueitemr[r\ content_typer]s r"encode_urlencoded_datarns(*JjjlD U edE] +   uUt%;D%ABU V   s$:5$AB C D Zt , 3 3G , ). z5Use 'content=<...>' to upload raw bytes/text content.) stacklevelr$) rGr warningswarnDeprecationWarningr_rtrnrr)rZrhrprrqmessages r"encode_requestrs  4 9J g1a@d##g&& $TZRAA %d++ 4  z# r$c| t|S| t|S| t|S| t|Sit dfS)zc Handles encoding the given `content`, returning a two-tuple of (, ). r$)r_rxr{rr)rZrwrzrs r"encode_responsersWg&& 4  4  4  z# r$)rZz4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r+7tuple[dict[str, str], SyncByteStream | AsyncByteStream])rhrr+!tuple[dict[str, str], ByteStream])rhrrprrq bytes | Noner+z&tuple[dict[str, str], MultipartStream])rwrTr+r)rzrTr+r)rr r+r)NNNNN) rZzRequestContent | NonerhzRequestData | NonerpzRequestFiles | Noner Any | Nonerqrr+r)NNNN) rZzResponseContent | Nonerw str | Nonerzrrrr+r). __future__rr9rcollections.abcrrrrrr rr rtypingr urllib.parser _exceptionsrr _multipartr_typesrrrrrr_utilsrr__all__rr4rBrKr_rnrtrxr{rrrr2r$r"rsS"ee$#5'A ..$$0*o*>  I AI<I: % *6B+%%%&*#!%!  "          = H'+  #     = r$