|
Server : nginx/1.24.0 System : Linux ip-172-31-33-48 6.14.0-1011-aws #11~24.04.1-Ubuntu SMP Fri Aug 1 02:07:25 UTC 2025 x86_64 User : www-data ( 33) PHP Version : 8.3.6 Disable Function : NONE Directory : /lib/python3/dist-packages/twisted/trial/_dist/__pycache__/ |
Upload File : |
�
Ϫ�f� � � � U d Z ddlmZmZ ddlmZmZmZmZm Z ddl
m Z m Z e d� Z
e d� Z e d� Zde
d ee
d
e
fd �Zd ee
gef d
ee
d
ee
fd�Zdee
dee d
efd�Zdee
egef d
eee
gef fd�Zdeegef dee
gef d
ee
gef fd�Z ee j, e ee� e d� � � Zeee
ge d f ed< dee
gef deg ee
f d
e
fd�Zdeege
f d
eg e
f fd �Zy) z1
General functional-style helpers for disttrial.
� )�partial�wraps)� Awaitable�Callable�Iterable�Optional�TypeVar)�Deferred�succeed�_A�_B�_C�default�optional�returnc � � |�| S |S )z�
Get a definite value from an optional value.
@param default: The value to return if the optional value is missing.
@param optional: The optional value to return if it exists.
� )r r s �@/usr/lib/python3/dist-packages/twisted/trial/_dist/functional.py� fromOptionalr s � � ���� �O� � condition�xsc # �6 K � |D ] } | |� r|�� � y y�w)z�
:return: An iterable over C{xs} that stops when C{condition} returns
``False`` based on the value of iterated C{xs}.
Nr )r r �xs r � takeWhiler s& � �� �
� �� �Q�<��G� � �s ��a�bc � �: K � | � d{ ��� |� d{ ��� S 7 �7 ��w)z�
Wait for one action to complete and then another.
If either action fails, failure is propagated. If the first action fails,
the second action is not waited on.
Nr )r r s r �sequencer + s � �� � �G�G��7�N� �� �s ��� ����fc �. � � t � � � fd�� }|S )zc
Create a function like another but with the order of the first two
arguments flipped.
c � �� �|| � S �Nr )r r r s �r �gzflip.<locals>.g< s �� ���A�w�r �r )r r$ s ` r �flipr& 6 s" �� � �1�X�� ��
�Hr �fx�fyc �N � �� t � � t �� � �fd�� � }|S )z�
Create a function that calls one function with an argument and then
another function with the result of the first function.
c � �� � �| � � S r# r )r r' r( s ��r r$ zcompose.<locals>.gI s �� � �"�Q�%�y�r r% )r' r( r$ s `` r �composer+ C s. �� � �2�Y�
�2�Y�� � ��
�Hr N�
discardResult� predicate�actionc � �D K � |� � d{ ��� } | |� s|S �7 ��w)z�
Call a function repeatedly until its result fails to satisfy a predicate.
@param predicate: The check to apply.
@param action: The function to call.
@return: The result of C{action} which did not satisfy C{predicate}.
Nr )r- r. �results r � iterateWhiler1 X s) � �� � � �x� ���� ��M� � �s � � � c �( � �� d�dt f�� fd� }|S )z�
Wrap a function with another that automatically passes an integer counter
of the number of calls that have gone through the wrapper.
r r c �8 �� ��� } �dz
�| S # �dz
�w xY w)N� r )r0 �counterr s ��r r$ zcountingCalls.<locals>.gr s, �� � ��w�Z�F� �q�L�G��
��
�q�L�G�s � �)r )r r$ r5 s ` @r �
countingCallsr6 k s �� �
�G��r� �
�Hr ) �__doc__� functoolsr r �typingr r r r r �twisted.internet.deferr
r r r
r r �boolr r r& r+ �
fromCoroutiner, �__annotations__r1 �intr6 r r r �<module>r? s� ��� %� C� C� 4� �T�]�� �T�]�� �T�]��
�"�
��� �
��
� ��2�$��*�-� �8�B�<� �H�R�L� ��i��m� � �"�
� �"� �
�H�b�"�X�r�\� "�
�x��R��"� �'=�
�
��"��r��"�
��"��r��(:�
�x���b��?Q�
� <C� ��� �D��N�G�D�M�*�<�
�x��2� ���$� �7�8� � ����d�
�#�� �R��2� �&� '�� ��&
�X�s�e�R�i�(�
�X�b�"�f�-=�
r