o
�J�h� � @ s� d dl mZ d dlZd dlZd dlZd dlmZmZmZm Z d dl
m Z m Z d dl
Zejdkr6d dl
mZ nd dlmZ ed�Ze d�Zd d
d�Zd!dd�ZG dd� de�Zd"dd�Zd#d d �ZdS )$� )� annotationsN)�
AsyncIterator� Coroutine�Iterable�Iterator)�Callable�TypeVar)� �
)� ParamSpec�P�T�args�tuple[Callable, dict]�return�Nonec � s� �t �dt� t�� 4 I d H �'� d� fdd� }| D ]\}}� �|tj|fi |��� qW d �I d H d S 1 I d H s<w Y d S ) NzOrun_until_first_complete is deprecated and will be removed in a future version.�func�Callable[[], Coroutine]r r c � s �| � I d H � j �� d S �N)� cancel_scope�cancel)r ��
task_group� �SC:\pinokio\api\whisper-webui.git\app\env\lib\site-packages\starlette\concurrency.py�run s � z%run_until_first_complete.<locals>.run)r r r r )�warnings�warn�DeprecationWarning�anyio�create_task_group�
start_soon� functools�partial)r r r �kwargsr r r �run_until_first_complete s �� �.�r% r �Callable[P, T]�P.argsr$ �P.kwargsc � s, �t j| g|�R i |��} tj�| �I d H S r )r" r# r � to_thread�run_sync)r r r$ r r r �run_in_threadpool$ s �r+ c @ s e Zd ZdS )�_StopIterationN)�__name__�
__module__� __qualname__r r r r r, ) s r, �iterator� Iterator[T]c C s zt | �W S ty t�w r )�next�
StopIterationr, )r0 r r r �_next- s
�r4 � Iterable[T]�AsyncIterator[T]c C s> �t | �} z
tj�t|�I d H V W n
ty Y d S w qr )�iterr r) r* r4 r, )r0 Z as_iteratorr r r �iterate_in_threadpool7 s � ��r8 )r r r r )r r& r r' r$ r( r r
)r0 r1 r r
)r0 r5 r r6 )�
__future__r r" �sysr �collections.abcr r r r �typingr r Zanyio.to_threadr � version_infor �typing_extensionsr r
r% r+ � Exceptionr, r4 r8 r r r r �<module> s"