Ë
|
ê^ià[ ã óX U d Z ddlmZ ddlZddlZddlmZ ddlmZ ddl m
|
Z
|
m Z ddl Z ddl mZmZmZmZ e
|
rddlmZ d d
|
lmZ d d lmZ d Zd ZdZdZdZ G d de « Z G d de « Z G d de « Z d0dZ! G d dejD « Z# G d d« Z$ G d d ejD « Z%d1d Z&d1d Z'd1d Z(d1d!Z)dZ*d"e+d#< e)« r e'« r e&« s e(« s e$« Z*ndZ*d$Z,d2d%Z-d&a.d3d'Z/d&a0d3d(Z1d4d)Z2 d5d*Z3 d6d+Z4d1d,Z5d1d-Z6d7d.Z7d1d/Z8y)8aä
|
Support for streaming http requests in emscripten.
|
|
A few caveats -
|
|
If your browser (or Node.js) has WebAssembly JavaScript Promise Integration enabled
|
https://github.com/WebAssembly/js-promise-integration/blob/main/proposals/js-promise-integration/Overview.md
|
*and* you launch pyodide using `pyodide.runPythonAsync`, this will fetch data using the
|
JavaScript asynchronous fetch api (wrapped via `pyodide.ffi.call_sync`). In this case
|
timeouts and streaming should just work.
|
|
Otherwise, it uses a combination of XMLHttpRequest and a web-worker for streaming.
|
|
This approach has several caveats:
|
|
Firstly, you can't do streaming http in the main UI thread, because atomics.wait isn't allowed.
|
Streaming only works if you're running pyodide in a web worker.
|
|
Secondly, this uses an extra web worker and SharedArrayBuffer to do the asynchronous fetch
|
operation, so it requires that you have crossOriginIsolation enabled, by serving over https
|
(or from localhost) with the two headers below set:
|
|
Cross-Origin-Opener-Policy: same-origin
|
Cross-Origin-Embedder-Policy: require-corp
|
|
You can tell if cross origin isolation is successfully enabled by looking at the global crossOriginIsolated variable in
|
JavaScript console. If it isn't, streaming requests will fallback to XMLHttpRequest, i.e. getting the whole
|
request into a buffer and then returning it. it shows a warning in the JavaScript console in this case.
|
|
Finally, the webworker which does the streaming fetch is created on initial import, but will only be started once
|
control is returned to javascript. Call `await wait_for_streaming_ready()` to wait for streaming fetch.
|
|
NB: in this code, there are a lot of JavaScript objects. They are named js_*
|
to make it clear what type of object they are.
|
é )Ú annotationsN)ÚParser)Úfiles)Ú TYPE_CHECKINGÚAny)ÚJsArrayÚ JsExceptionÚJsProxyÚto_js)ÚBufferé )ÚEmscriptenRequest)ÚEmscriptenResponse)z
|
user-agentéÿÿÿÿéþÿÿÿéýÿÿÿéüÿÿÿc ó6 e Zd Z dddd d fdZ xZS )Ú _RequestErrorN©ÚrequestÚresponsec ób || _ || _ || _ t | | j « y ©N)r r ÚmessageÚsuperÚ__init__)Úselfr r r Ú __class__s õs H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\urllib3/contrib/emscripten/fetch.pyr z_RequestError.__init__H s+ ø ð Ø Ø Ü Ñ Õ&ó r )r z
|
str | Noner úEmscriptenRequest | Noner úEmscriptenResponse | None)Ú__name__Ú
|
__module__Ú __qualname__r Ú __classcell__©r s @r r r G s; ø ð #ð
|
'ð -1Ø.2ñ
|
'àð
|
'ð *ð
|
'ð
|
,÷
|
'ñ
|
'r! r c ó e Zd Zy)Ú_StreamingErrorN©r$ r% r& © r! r r* r* U ó Ør! r* c ó e Zd Zy)Ú _TimeoutErrorNr+ r, r! r r/ r/ Y r- r! r/ c óL t | t j j ¬« S )N)Údict_converter)r ÚjsÚObjectÚ fromEntries)Údict_vals r Ú_obj_from_dictr6 ] s Ü ¬"¯)©)×*?Ñ*?Ô @Ð@r! c ó e Zd Z d
|
dZd dZd dZed d« Zd fd Zd dZ d dZ
|
d dZ d d Z xZ S )Ú _ReadStreamc ó¶ || _ || _ d| _ d| _ || _ || _ |dkD rt d|z « nd | _ d| _ d| _ || _
|
y )Nr éè TF) Ú
|
int_bufferÚ byte_bufferÚread_posÚread_lenÚ connection_idÚworkerÚintÚtimeoutÚis_liveÚ
|
_is_closedr )r r; r< rB r@ r? r s r r z_ReadStream.__init__b s] ð %Ø&ÔØ Ø Ø *ÔØ Ø.5¸ªks4 '>Ô*¸t Ø Ø Ø18 r! c ó$ | j « y r ©Úclose©r s r Ú__del__z_ReadStream.__del__v ó Ø
|
|
r! c ó | j S r ©rD rH s r Ú is_closedz_ReadStream.is_closedz ó ØÐ r! c ó" | j « S r ©rM rH s r Úclosedz_ReadStream.closed~ ó à~~Ó Ð r! c ó | j « ry d| _ d| _ d | _ d | _ d| _ d | _ | j r7| j j t d| j i« « d| _ t | 5 « y )Nr TrG F)rM r> r= r; r< rD r rC r@ Ú postMessager6 r? r rG ©r r s r rG z_ReadStream.close st ø Ø >>Ô Ø Ø Ø Ø Ø ÔØ Ø Ø <<Ø KK× #Ñ #¤N°G¸T×=OÑ=OÐ3PÓ$QÔ RØ DLÜ r! c ó y©NTr, rH s r Úreadablez_ReadStream.readable ó Ør! c ó y©NFr, rH s r Úwritablez_ReadStream.writable ó Ør! c ó yr[ r, rH s r Úseekablez_ReadStream.seekable r] r! c ób | j st d| j d ¬« | j dk( rYt j
|
j | j dt « | j j t d| j i« « t j
|
j | j dt | j « dk( rt | j d }|dkD r|| _ d| _ n|t k( rs| j d }t j" j% « }|j' | j( j+ d|« « }t d| | j d ¬« d| _ | j/ « yt1 | j t3 t5 |« « « }| j( j7 | j | j |z « j9 « }|t5 |« d| | xj |z c_ | xj |z c_ |S ) Nz,No buffer for stream in _ReadStream.readintor r ÚgetMorez timed-outr úException thrown in fetch: F) r; r* r r> r2 ÚAtomicsÚstoreÚ ERROR_TIMEOUTr@ rT r6 r? ÚwaitrB r/ r= ÚERROR_EXCEPTIONÚ TextDecoderÚnewÚdecoder< ÚslicerC rG ÚminÚlenÚ
|
memoryviewÚsubarrayÚto_py)r Úbyte_objÚdata_lenÚ
|
string_lenÚ
|
js_decoderÚjson_strÚ
|
ret_lengthro s r Úreadintoz_ReadStream.readinto sÀ ØÜ!Ø>Ø Ø ôð ð
|
==AÓ ä JJ× Ñ T__¨a´ Ô ?Ø KK× #Ñ #¤N°I¸t×?QÑ?QÐ3RÓ$SÔ Tä
|
|
§¡°´MÀ4Ç<Á<ÓPØ ò ô $Ð#Ø qÑ)HØ!|Ø ( Ø ! Ø_Ò,Ø !__¨QÑ /
|
ä ^^× /Ñ /Ó 1
|
Ø%×,Ñ,¨T×-=Ñ-=×-CÑ-CÀAÀzÓ-RÓSÜ%Ø1°(°Ð<Ø LLØ !ôð ð % Ø
|
|
Øä ¬¬J°xÓ,@Ó(AÓB
|
Ø×#Ñ#×,Ñ,Ø MM4==¨:Ñ5ó
|
ç
|
%'ð ð .6
|
8Ó QzÐ*Ø Ñ# Ø Ñ# ØÐr! ) r; r r< r rB Úfloatr@ r
|
r? rA r r ©ÚreturnÚNone©rz Úbool©rq r rz rA )r$ r% r& r rI rM ÚpropertyrQ rG rX r\ r_ rw r' r( s @r r8 r8 a sy ø ð9àð9ð ð9ð ð 9ð
|
ð 9ð ð 9ð #ó9ó(ó ð ò ó ð õ ó óó÷,r! r8 c ó e Zd ZddZddZy)Ú_StreamingFetcherc óà d _ t t « j d« j d¬« }t
|
j j t |gd¬« t ddi« « }d fd }t
|
j j |« }t
|
j j j |« _ t
|
j j j |« _ y )
|
NFzemscripten_fetch_worker.jszutf-8)Úencoding)Úcreate_pyproxiesÚtypezapplication/javascriptc óh d fd }dfd }|j _ |j _ y )Nc ó$ d_ | « y rW )Ústreaming_ready)ÚeÚ js_resolve_fnr s r ÚonMsgzC_StreamingFetcher.__init__.<locals>.promise_resolver.<locals>.onMsg× s ø Ø'+Ô$Ù aÕ r! c ó | « y r r, )r Ú js_reject_fns r ÚonErrzC_StreamingFetcher.__init__.<locals>.promise_resolver.<locals>.onErrÛ s
|
ø Ù Qr! )r r
|
rz r{ )Ú js_workerÚ onmessageÚonerror)r r r r r s `` r Úpromise_resolverz4_StreamingFetcher.__init__.<locals>.promise_resolverÖ s' ú ö !õ ð (-DNNÔ $Ø%*DNNÕ "r! )r r
|
r r
|
rz r{ )r r Ú __package__ÚjoinpathÚ read_textr2 ÚBlobri r r6 ÚURLÚcreateObjectURLÚ
|
globalThisÚWorkerr ÚPromiseÚjs_worker_ready_promise)r Ústreaming_worker_codeÚ js_data_blobr Ú js_data_urls ` r r z_StreamingFetcher.__init__É s´ ø à $Ô ä +Ó ß XÐ2Ó 3ß Y YÓ (ð ô
|
ww{{Ü Ð(Ð)¸EÔ BÜ FÐ$<Ð=Ó >ó
|
õ
|
+ô ff×,Ñ,¨\Ó: Ü ×-Ñ-×1Ñ1°+Ó>Ü')§}¡}×'<Ñ'<×'@Ñ'@ÐAQÓ'RÕ$r! c óØ |j j « D ci c] \ }}|t vs|| }}}|j }|t |« |j
|
d}|j dkD rt d|j z « nd }t j j d« }t j j |« } t j j |d« }
|
t j j | dt « t j j! | d« t j" j |j$ t j& « j( } | j* j- t/ || |d« « t j j1 | dt |« | d t k( rt3 d|d ¬« | d t4 k( r| d } t j6 j « } | j9 |
|
j; d| « « }t= j> |« }tA ||d
|
|d tC | |
|
|j | j* |d |« ¬ « S | d tD k( rU| d } t j6 j « } | j9 |
|
j; d| « « }tG d| |d ¬« tG d| d |d ¬« c c}}w )N)ÚheadersÚbodyÚmethodr r: i é )ÚbufferÚurlÚ fetchParamsz'Timeout connecting to streaming requestr r Ústatusr¡ Ú connectionID)r Ú status_coder¡ r¢ rb z%Unknown status from worker in fetch: )$r¡ ÚitemsÚHEADERS_TO_IGNOREr¢ r r£ rB rA r2 ÚSharedArrayBufferri Ú
|
Int32ArrayÚ
|
Uint8Arrayrc rd re Únotifyr r¦ ÚlocationÚhrefr rT r6 rf r/ ÚSUCCESS_HEADERrh rj rk ÚjsonÚloadsr r8 rg r* )r r ÚkÚvr¡ r¢ Ú
|
fetch_datarB Újs_shared_bufferÚ js_int_bufferÚjs_byte_bufferÚjs_absolute_urlrs rt ru Ú response_objs r Úsendz_StreamingFetcher.sendå s à $__× 2Ñ 2Ó 4÷
|
ÙQ¸ÔARÒ8RAqDð
|
ñ
|
ð ||Ø!(´%¸³+ÈÏ É ÑX
|
à18· ± À1Ò1D#dW__Ñ,Ô-È$Ü ×/Ñ/×3Ñ3°GÓ<ÐÜ ×)Ñ)Ð*:Ó; Ü ×*Ñ*Ð+;¸QÓ?ä
|
|
|
×Ñ ¨¬=Ô9Ü
|
|
|
×Ñ-¨Ô+Ü &&** W§[¡[´"·+±+Ó>×CÑCØ ×"Ñ"Ü à .Ø*Ø#-ñó ô
|
ô
|
|
q¬-¸ÔAØ Ñ }Ò ,Ü Ø9Ø Ø ôð ð
|
1Ñ ¤ Ò /ð ' qÑ)Jä ×+Ñ+Ó-Jð "×(Ñ(¨ ×)=Ñ)=¸aÀÓ)LÓMHä :: hÓ/LÜ%Ø Ø (¨Ñ 2Ø$ YÑ/Ü Ø!Ø"ØOOØNNØ Ñ0Øó ô ð ð 1Ñ ¤ Ò 0Ø& qÑ)Jä ×+Ñ+Ó-JØ!×(Ñ(¨ ×)=Ñ)=¸aÀÓ)LÓMHÜ!Ø-¨h¨ZÐ8À'ÐTXôð ô "Ø7¸ ÀaÑ8HÐ7IÐJØ Ø ôð ùóC
|
s
|
K&¯K&Nry ©r r rz r )r$ r% r& r r¾ r, r! r r r È s óSô8Fr! r c ó e Zd ZdZ d dZd dZddZedd« Zd fd Z ddZ
|
ddZ dd Z dd
|
Z dd Z xZS )Ú_JSPIReadStreamaF
|
A read stream that uses pyodide.ffi.run_sync to read from a JavaScript fetch
|
response. This requires support for WebAssembly JavaScript Promise Integration
|
in the containing browser, and for pyodide to be launched via runPythonAsync.
|
|
:param js_read_stream:
|
The JavaScript stream reader
|
|
:param timeout:
|
Timeout in seconds
|
|
:param request:
|
The request we're handling
|
|
:param response:
|
The response this stream relates to
|
|
:param js_abort_controller:
|
A JavaScript AbortController object, used for timeouts
|
c ó || _ || _ d| _ d| _ || _ || _ d | _ d| _ || _ y )NFr ) Újs_read_streamrB rD Ú_is_doner r Úcurrent_bufferÚcurrent_buffer_posÚjs_abort_controller)r rà rB r r rÇ s r r z_JSPIReadStream.__init__D sG ð -ÔØ Ø Ø Ø18 Ø3; Ø "ÔØ"#Ô Ø#6Õ r! c ó$ | j « y r rF rH s r rI z_JSPIReadStream.__del__V rJ r! c ó | j S r rL rH s r rM z_JSPIReadStream.is_closedZ rN r! c ó" | j « S r rP rH s r rQ z_JSPIReadStream.closed^ rR r! c óÚ | j « ry d| _ d| _ | j j « d | _ d| _ d| _ d | _ d | _ t | ) « y )Nr T) rM r> r= rà ÚcancelrD rÄ r r r rG rU s r rG z_JSPIReadStream.closeb s] ø Ø >>Ô Ø Ø Ø Ø ×Ñ×"Ñ"Ô$Ø "ÔØ Ø Ø Ø Ü r! c ó yrW r, rH s r rX z_JSPIReadStream.readableo rY r! c ó yr[ r, rH s r r\ z_JSPIReadStream.writabler r] r! c ó yr[ r, rH s r r_ z_JSPIReadStream.seekableu r] r! c ó t | j j « | j | j | j
|
| j ¬« }|j rd| _ y|j j « | _ d| _ y)Nr TFr ) Ú_run_sync_with_timeoutrà ÚreadrB rÇ r r ÚdonerÄ Úvaluerp rÅ rÆ )r Ú result_jss r Ú_get_next_bufferz _JSPIReadStream._get_next_bufferx so Ü*Ø × Ñ × $Ñ $Ó &Ø LLØ × $Ñ $ØLLØ]]ô
|
ð >>Ø DMØà"+§/¡/×"7Ñ"7Ó"9DÔ Ø&'DÔ #Ør! c ó° | j -| j « r | j | j « yt t |« t | j « | j
|
z
|
« }| j | j
|
| j
|
|z |d| | xj
|
|z c_ | j
|
t | j « k( rd | _ |S )Nr )rÅ rÖ rG rl rm rÆ )r rq rv s r rw z_JSPIReadStream.readinto sÃ Ø × Ñ Ð &Ø×(Ñ(Ô*¨d×.AÑ.AÐ.IØ
|
|
ØÜÜ M3t× 2Ñ 2Ó3°d×6MÑ6MÑMó
|
|
ð "&×!4Ñ!4Ø × #Ñ # d×&=Ñ&=À
|
Ñ&Jð"
|
:Ð ð × Ò :Ñ-Õ Ø × "Ñ "¤c¨$×*=Ñ*=Ó&>Ò >Ø"&DÔ ØÐr! )
|
rà r rB rx r r r r rÇ r ry r| r~ )r$ r% r& Ú__doc__r rI rM r rQ rG rX r\ r_ rÖ rw r' r( s @r rÁ rÁ . sy ø ñð*7àð7ð ð7ð #ð 7ð
|
%ð 7ð !ó 7ó$ó ð ò ó ð õ óóóó÷ r! rÁ c ó t t d« xr3 t t d« xr! t j t j k( S )NÚwindowr )Úhasattrr2 r rÚ r, r! r Úis_in_browser_main_threadrÜ s- Ü 2xÓ Ò Q¤W¬R°Ó%8Ò Q¼R¿W¹WÌÏ É Ñ=QÐQr! c óF t t d« xr t j S )NÚcrossOriginIsolated)rÛ r2 rÞ r, r! r Úis_cross_origin_isolatedrß s Ü 2Ð,Ó -Ò H´"×2HÑ2HÐHr! c óø t t d« xri t t j d« xrM t t j j d« xr' t j j j dk( S )NÚprocessÚreleaseÚnameÚnode©rÛ r2 rá râ rã r, r! r Ú
|
is_in_noderæ ¢ s\ äIÓ ò .Ü BJJ Ó *ò .ä BJJ×&Ñ&¨Ó /ò .ô JJ× Ñ × #Ñ # vÑ -ð r! c óF t t d« xr t t d« S )Nr r )rÛ r2 r, r! r Úis_worker_availablerè « s Ü 2xÓ Ò 8¤W¬R°Ó%8Ð8r! z_StreamingFetcher | NoneÚ_fetcherzurllib3 only works in Node.js with pyodide.runPythonAsync and requires the flag --experimental-wasm-stack-switching in versions of node <24.c óÆ t « r t | d« S t « rt t | d ¬« t
|
r t « rt
|
j | « S t « y )NT©r r r ) Úhas_jspiÚsend_jspi_requestræ r ÚNODE_JSPI_ERRORré r r¾ Ú_show_streaming_warning©r s r Úsend_streaming_requestrñ Á sQ ÜzÜ ¨$Ó/Ð/Ü ÜÜ#ØØô
|
ð
|
õ OÔ%Ü}}WÓ%Ð%ä Ô!Ør! Fc óX t s$da d} t j j | « y y )NTz8Warning: Timeout is not available on main browser thread)Ú_SHOWN_TIMEOUT_WARNINGr2 ÚconsoleÚwarn)r s r Ú_show_timeout_warningrö Õ s% å !Ø!%Ð ØLÜ
|
|
|
Õ ð "r! c óÄ t sZda d} t « s| dz } t « r| dz } t « s| dz } t « du r| dz } dd lm} |j | « y y )
|
NTz%Can't stream HTTP requests because:
|
z$ Page is not cross-origin isolated
|
z+ Python is running in main browser thread
|
z> Worker or Blob classes are not available in this environment.Fz² Streaming fetch worker isn't ready. If you want to be sure that streaming fetch
|
is working, you need to call: 'await urllib3.contrib.emscripten.fetch.wait_for_streaming_ready()`r )rô )Ú_SHOWN_STREAMING_WARNINGrß rÜ rè r r2 rô rõ )r rô s r rï rï à ss å #Ø#'Ð Ø:Ü'Ô)Ø Ð>Ñ >GÜ $Ô &Ø ÐEÑ EGÜ"Ô$Ø ÐWÑ WGÜ Ó Ñ %Ø ð eñ eGå à WÕ ð $r! c óª t « r t | d« S t « rt t | d ¬« t
|
j j « }t « s1d|_ | j rEt | j dz « |_
|
n'|j d« | j r
|
t « |j | j | j d« | j" j% « D ]. \ }}|j' « t( vs |j+ ||« 0 |j- t/ | j0 « « t3 t5 « j7 |j9 « « « }t « s)|j: j= « j? « }n|j: jA d« }tC |jD ||| ¬« S # tF $ rh}|jH dk( rtK |jL | ¬ « |jH d
|
k( rt |jL | ¬ « t |jL | ¬ « d }~ww xY w) NFrë Ú arraybufferr: z text/plain; charset=ISO-8859-15z ISO-8859-15©rª r¡ r¢ r Ú TimeoutErrorrð Ú NetworkError)'rì rí ræ r rî r2 ÚXMLHttpRequestri rÜ Ú responseTyperB rA ÚoverrideMimeTyperö Úopenr£ r¦ r¡ r« Úlowerr¬ ÚsetRequestHeaderr¾ r r¢ Údictr ÚparsestrÚgetAllResponseHeadersr rp ÚtobytesÚencoder r¨ r rã r/ r )r Újs_xhrrã rÔ r¡ r¢ Úerrs r Ú send_requestr ó sÌ ÜzÜ ¨%Ó0Ð0Ü ÜÜ#ØØô
|
ð
|
ð
|
%>Ü×"Ñ"×&Ñ&Ó(ä(Ô*Ø"/FÔ ØÜ!$ W§_¡_°tÑ%;Ó!<à × #Ñ #Ð$EÔ FØô &Ô'à GNN G§K¡K°Ô7Ø"??×0Ñ0Ó2ò 5KD%Øzz|Ô#4Ò4Ø×'Ñ'¨¨eÕ4ð 5ð E',,Ó'Ô(ävx×(Ñ(¨×)EÑ)EÓ)GÓHÓIä(Ô*Ø??×(Ñ(Ó*×2Ñ2Ó4Dà??×)Ñ)¨-Ó8DÜ!Ø ¨w¸TÈ7ô
|
ð
|
øô ò >Ø 88~Ò %Ü § ¡ °WÔ=Ð =Ø XX Ò 'Ü § ¡ °WÔ=Ð =ô § ¡ °WÔ=Ð =ûð>ús ´C G! ÄCG! Ç! IÇ*A#I É Ic ó¬ | j }t j j « }| j j « D ci c] \ }}|t vs|| }}}| j }|t |« | j |j d}t « rd|d< t j | j t |« « } t | ||| d¬« }
|
i }|
|
j j! « } | j# « } t% | dd« rn2t' | j( d « |t' | j( d « < P|
|
j* } d
|
}t- | |d
|
| ¬ « }|r6|
|
j V|
|
j j/ « }t1 ||| ||« }n,t |
|
j3 « ||| |¬« j5 « }||_ |S c c}}w ) a7
|
Send a request using WebAssembly JavaScript Promise Integration
|
to wrap the asynchronous JavaScript fetch api (experimental).
|
|
:param request:
|
Request to send
|
|
:param streaming:
|
Whether to stream the response
|
|
:return: The response object
|
:rtype: EmscriptenResponse
|
)r¡ r¢ r£ ÚsignalÚmanualÚredirectNr rÓ Fr r r! rû )rB r2 ÚAbortControllerri r¡ r« r¬ r¢ r r£ r Ú _is_node_jsÚfetchr¦ r6 rÑ ÚentriesÚnextÚgetattrÚstrrÔ r¨ r Ú getReaderrÁ Ú arrayBufferrp )r Ú streamingrB rÇ r¶ r· r¡ Úreq_bodyr¸ Úfetcher_promise_jsÚ response_jsÚ header_iterÚ iter_value_jsrª r¢ r Úbody_stream_jss r rí rí $ sÑ ð ooGÜ ×,Ñ,×0Ñ0Ó2ÐØ '§¡× 5Ñ 5Ó 7×V1¸1ÔDUÒ;Uq!tÐVGÑVØ||HàÜhØ..Ø%×,Ñ,ñ Jô }Ø!)
|
:Ñ ä '§+¡+¬~¸jÓ/IÓJÐô )ØØØØØô Kð GØ ×%Ñ%×-Ñ-Ó/KØ
|
Ø#×(Ñ(Ó* Ü = &¨%Ô 0Ø ä36°}×7JÑ7JÈ1Ñ7MÓ3NGC ×+Ñ+¨AÑ.Ó/Ñ 0ð ð ×$Ñ$KØ!$Dä!Ø ¨°sÀGôHñ à × Ñ Ð 'à (× -Ñ -× 7Ñ 7Ó 9NÜ"Ø ¨°(Ð<OóDô &Ø × #Ñ #Ó %Ø Ø ØØ ô
|
÷ %'ð ð HMØ Oùós Ws ÁGÁGc ó d}|dkD r;t j |j j |« t |dz « « } ddlm} || « |t j |« S S # t $ r:}|j dk( rt d||¬« t |j ||¬« d}~ww xY w# |t j |« w w xY w)ak
|
Await a JavaScript promise synchronously with a timeout which is implemented
|
via the AbortController
|
|
:param promise:
|
Javascript promise to await
|
|
:param timeout:
|
Timeout in seconds
|
|
:param js_abort_controller:
|
A JavaScript AbortController object, used on timeout
|
|
:param request:
|
The request being handled
|
|
:param response:
|
The response being handled (if it exists yet)
|
|
:raises _TimeoutError: If the request times out
|
:raises _RequestError: If the request raises a JavaScript exception
|
|
:return: The result of awaiting the promise.
|
Nr r: )Úrun_syncÚ
|
AbortErrorzRequest timed outrë ) r2 Ú
|
setTimeoutÚabortÚbindrA Ú pyodide.ffir! Ú clearTimeoutr rã r/ r r )ÚpromiserB rÇ r r Útimer_idr! r
|
s r rÑ rÑ r sÌ ð> HØ{Ü==Ø × %Ñ %× *Ñ *Ð+>Ó ?ÄÀWÈtÁ^ÓATó
|
ð&Ý(ñ Ó ð Ð Ü OOHÕ %ð øô ò YØ 88|Ò #Ü Ø+°WÀxôð ô ¨¯ © ¸WÈxÔXÐ Xûð Yûð Ð Ü OOHÕ %ð ús$ Á A* Á* B-Á35B(Â(B-Â-B0 Â0C
|
c óR ddl m} m} t | « « S # t $ r Y yw xY w)a
|
Return true if jspi can be used.
|
|
This requires both browser support and also WebAssembly
|
to be in the correct state - i.e. that the javascript
|
call into python was async not sync.
|
|
:return: True if jspi can be used.
|
:rtype: bool
|
r ©Ú can_run_syncr! F)r& r, r! r} Ú ImportErrorr+ s r rì rì ¨ s) ðß6äLNÓ#Ð#øÜ ò Ùðús &¥&c ó¬ t t d« xrC t t j d« xr' t j j j dk( S )z_
|
Check if we are in Node.js.
|
|
:return: True if we are in Node.js.
|
:rtype: bool
|
rá râ rä rå r, r! r r r » sE ô IÓ ò .Ü BJJ Ó *ò .ô JJ× Ñ × #Ñ # vÑ -ð r! c ó0 t rt j S y r )ré r r, r! r r r Ê s ÝÜ×'Ñ'Ð'àr! c óN K t rt j d { yy7 w)NTF)ré r r, r! r Úwait_for_streaming_readyr1 Ñ s# è ø ÝÜ×.Ñ.×.Ð.Øàð /ús %#%)r5 zdict[str, Any]rz r
|
r| )r r rz r# ry r¿ )r r r r} rz r ) r( r rB rx rÇ r r r" r r# rz r )rz z bool | None)9rØ Ú
|
__future__r Úior´ Ú email.parserr Úimportlib.resourcesr Útypingr r r2 r& r r r
|
r Útyping_extensionsr r r r r r¬ r³ Ú SUCCESS_EOFre rg Ú Exceptionr r* r/ r6 Ú RawIOBaser8 r rÁ rÜ rß ræ rè ré Ú__annotations__rî rñ ró rö rø rï r rí rÑ rì r r r1 r, r! r ú<module>r< s¢ ðò"õH #ã Û Ý Ý %ß %ã ÷ó ñ Ý(å &Ý (ðð $Ð àØ Ø Øô 'Iô 'ô mô ô Mô óAôd",,ô d÷Ncñ côLhbllô hóXRóIóó9ð &*Ð
|
"Ó )áÔÙ Ô Ñ(AÔ(CÙ \á Ó"HàHð ð óð" Ð ó!ð !Ð ó ó&.>ðbKØ ðKØ+/ðKàóKð\3&Ø ð3&à ð3&ð ð3&ð &ð 3&ð
|
(ð 3&ð ó 3&óló& ó ôr!
|
