g ddlmZddlmZddlZddlZeddZGddejZeZ Gdd e Z d e fd Z dS) ) ContextVar)OptionalNcurrent_async_library_cvar)defaultceZdZdZdS) _ThreadLocalN)__name__ __module__ __qualname__nameK/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/sniffio/_impl.pyrr s DDDrrceZdZdS)AsyncLibraryNotFoundErrorN)r r r r rrrrsDrrreturncdtj}||St}||SdtjvrGddl} |j}n#t$r|j j}YnwxYw |dSn#t$rYnwxYwdtjvrddl m }|rdStd)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}") Nasynciorcurio) curio_runningz.unknown async library, or not in async context) thread_localr rgetsysmodulesr current_taskAttributeErrorTask RuntimeError curio.metarr)valuerrrs rcurrent_async_libraryr!sR  E  & * * , ,E  CK 5"/LL 5 5 5"<4LLL 5 |~~) y*    D #+,,,,,, =?? 7 #8  s$A A"!A"& A33 B?B) contextvarsrtypingrr threadingrlocalrrrrstrr!r rrr's"""""" 'Z $ 9?|~~         FsFFFFFFr