+ ^|iRt^RIt^RIt^RIt^RIHtRsRt!RR4t]!4t !RR4t Rt R t R t R R ltR#) a Async helper function that are invalid syntax on Python 3.5 and below. This code is best effort, and may have edge cases not behaving as expected. In particular it contain a number of heuristics to detect whether code is effectively async and need to run in an event loop or not. Some constructs (like top-level `return`, or `yield`) are taken care of explicitly to actually raise a SyntaxError and stay as close as possible to Python semantics. N)wrapsc\P!4# \dMi;i\e\P 4'd\P !4s\#)a:asyncio has deprecated get_event_loop Replicate it here, with our desired semantics: - always returns a valid, not-closed loop - not thread-local like asyncio's, because we only want one loop for IPython - if called from inside a coroutine (e.g. in ipykernel), return the running loop .. versionadded:: 8.0 )asyncioget_running_loop RuntimeError_asyncio_event_loop is_closednew_event_loop)r&rs&r __repr___AsyncIOProxy.__repr__Js  R00r caa\SPV4o\P!S4'd\ S4VV3Rl4pV#S#)c~<\P!S!V/VBSP4p\P!V4#r%)rrun_coroutine_threadsafer' wrap_future)argskwargsconcurrent_futureattrrs*, r _wrapped+_AsyncIOProxy.__getattr__.._wrappedRs=$+$D$D$)&)4+;+;%!**+<==r )getattrr&inspectiscoroutinefunctionr)rkeyr7r6sf& @r __getattr___AsyncIOProxy.__getattr__MsHtyy#&  & &t , ,4[ > > OKr c,\VP4#r%)dirr&rs&r __dir___AsyncIOProxy.__dir__]s499~r )r'r&N) rrrr__doc__r*r-r=rArrr s@r r#r#@s# &1 r r#c,^RIpVPV4#)z handler for curio autoawait N)curiorun) coroutinerEs& r _curio_runnerrHas 99Y r c2^RIpRpVPW 4#)Nc""VGRjxL #L5i)zv We need the dummy no-op async def to protect from trio's internal. See https://github.com/python-trio/trio/issues/89 Nr )rs&r loc_trio_runner..locms zzs  )triorF)async_fnrNrLs& r _trio_runnerrPjs 88C ""r cVPR4\RPVPR74h \dpTP uRp?#Rp?ii;i)z A runner that does not really allow async execution, and just advance the coroutine. See discussion in https://github.com/python-trio/trio/issues/608, Credit to Nathaniel Smith Nz%{coro_name!r} needs a real async loop) coro_name)sendrformatr StopIterationvalue)rexcs& r _pseudo_sync_runnerrXwsR  $  3 : :T]] : S  yys8 A AAAc0V^8dQhR\R\/#)cellreturn)strbool)rTs"r __annotate__r_s  3 4 r c \VRR\\R^4R7p\PVP ,\P8H# \ \\3dR#i;i)zDetect if a block of code needs to be wrapped in an `async def` If the code block has a top-level return statement or is otherwise invalid, `False` will be returned. z<>execPyCF_ALLOW_TOP_LEVEL_AWAIT)flagsF) compiler9astr: CO_COROUTINEco_flags SyntaxError ValueError MemoryError)r[codes& r _should_be_asyncrls`  $gc3OQT&U ##dmm3w7K7KKK [ 1sAAA,+A,)rCrerr: functoolsrrr r_asyncio_runnerr#rHrPrXrlr r r rosV  :!"B  # & r