o
    sh                     @   sn   d dl mZ d dlmZ d dlZd dlZedddZG dd dejZe Z	G dd	 d	e
Zd
efddZdS )    )
ContextVar)OptionalNcurrent_async_library_cvar)defaultc                   @   s   e Zd ZdZdS )_ThreadLocalN)__name__
__module____qualname__name r   r   a/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/sniffio/_impl.pyr      s    r   c                   @   s   e Zd ZdS )AsyncLibraryNotFoundErrorN)r   r   r	   r   r   r   r   r      s    r   returnc                  C   s   t j} | dur	| S t } | dur| S dtjv rCddl}z|j}W n ty.   |j	j}Y nw z
| dur8W dS W n	 t
yB   Y nw dtjv rSddlm} | rSdS td)ae  Detect 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}")

    Nasyncior   curio)curio_runningz.unknown async library, or not in async context)thread_localr
   r   getsysmodulesr   current_taskAttributeErrorTaskRuntimeError
curio.metar   r   )valuer   r   r   r   r   r   current_async_library   s6   )



r   )contextvarsr   typingr   r   	threadingr   localr   r   r   r   strr   r   r   r   r   <module>   s    