U ,hb¡ ã@sNddlmZddlmZddlZedddZGdd„deƒZedœd d „Z dS) é)Ú ContextVar)ÚOptionalNÚcurrent_async_library_cvar)Údefaultc@s eZdZdS)ÚAsyncLibraryNotFoundErrorN)Ú__name__Ú __module__Ú __qualname__©r r ú1/tmp/pip-unpacked-wheel-vrtgg_qo/sniffio/_impl.pyr sr)ÚreturncCs¸t ¡}|dk r|Sdtjkr4ddlm}|ƒr4dSdtjkr¬ddl}z |j}Wntk rl|j j}YnXz(|ƒdk r”dtj krŽt  d¡WdSWnt k rªYnXt dƒ‚dS)aeDetect which async library is currently running. The following libraries are currently supported: ================ =========== ============================ Library Requires Magic string ================ =========== ============================ **Trio** Trio v0.6+ ``"trio"`` **Curio** - ``"curio"`` **asyncio** ``"asyncio"`` **Trio-asyncio** v0.8.2+ ``"trio"`` or ``"asyncio"``, depending on current mode ================ =========== ============================ Returns: A string like ``"trio"``. Raises: AsyncLibraryNotFoundError: if called from synchronous context, or if the current async library was not recognized. Examples: .. code-block:: python3 from sniffio import current_async_library async def generic_sleep(seconds): library = current_async_library() if library == "trio": import trio await trio.sleep(seconds) elif library == "asyncio": import asyncio await asyncio.sleep(seconds) # ... and so on ... else: raise RuntimeError(f"Unsupported library {library!r}") NZcurior)Ú curio_runningÚasyncio)ééz.unknown async library, or not in async context)rÚgetÚsysÚmodulesZ curio.metar rÚ current_taskÚAttributeErrorZTaskÚ version_infoÚsetÚ RuntimeErrorr)Úvaluer rrr r r Úcurrent_async_librarys.)        ÿr) Z contextvarsrÚtypingrrrrrÚstrrr r r r Ús  ÿ