codekingpro/portable-devtools
114k
1�
2 ��j] � � � S r SSKJr SSKrSSKrSSKrSSKJr SSKJr SSK J3r4 SSK J r SSK J r SS K J
r
SS5K Jr \
" S 5 r\" S 5 rSS
jr " S S5 r " S S\ \ \5 r " S S\ \ \5 rSS jrSS jrg)aq 6This module provides signals, which are a simple dispatching system that allows any number of interested parties7to subscribe to events ("signals").8 9This is similar to the Blinker library (https://pypi.org/project/blinker/), with the following changes:10 - provides only a small subset of Blinker's functionality11 - supports type hints12 - supports async receivers.13� )� annotationsN)� Awaitable)�Callable)�Any)�cast)�Generic)� ParamSpec)�TypeVar�P�Rc � � [ U S5 ( a. [ [ R [ R " U 5 5 $ [ R " U 5 $ )zE14Like weakref.ref(), but using weakref.WeakMethod for bound methods.15�__self__)�hasattrr �weakref�ref�16WeakMethod)�objs �]D:\code\apps\devtools\python\user_packages\Python313\site-packages\mitmproxy/utils/signals.py�
make_weak_refr s< � � �s�J� � ��G�K�K��!3�!3�C�!8�9�9��{�{�3� � � c �8 � \ rS rSrSS jrS S jrS S jrS rSrg)17� _SignalMixin�( c � � / U l g �N�� receivers)�selfs r �__init__�_SignalMixin.__init__) s � �68��r c �P � [ U5 nU R R U5 g)zc18Register a signal receiver.19 20The signal will only hold a weak reference to the receiver function.21N)r r �append)r �receivers r �connect�_SignalMixin.connect, s � � !��*�� ��� � �h�'r c �j � U R Vs/ s H o"" 5 U:w d M UPM snU l g s snf r r )r r# �rs r �22disconnect�_SignalMixin.disconnect5 s' � �%)�^�^�G�^��q�s�h��!�^�G����Gs �0�0c / �� # � SnU R H nU" 5 nUb U" U0 UD6v � M SnM U( a, U R Vs/ s H oU" 5 c M UPM snU l g g s snf 7f)NFTr )r �args�kwargs�cleanupr r' s r �notify�_SignalMixin.notify8 sd � � ����>�>�C���A��}���(��(�(� �� "� �)-� � � K� �A�1�3�a� � K�D�N� �� K�s �AA)� A$�A$�A)r N)�return�None)r# r r0 r1 ) �__name__�23__module__� __qualname__�__firstlineno__r r$ r( r. �__static_attributes__� r r r r ( s � �9�(�H� Lr r c �L ^ � \ rS rSrSU 4S jjrSU 4S jjrSU 4S jjrSrU =r$ )� _SyncSignal�D c �^ >� [ R " U5 ( a e[ TU ]
U5 g r )�inspect�iscoroutinefunction�superr$ �r r# � __class__s �r r$ �_SyncSignal.connectE s& �� ��.�.�x�8�8�8�8�
����!r c �$ >� [ TU ] U5 g r �r> r( r? s �r r( �_SyncSignal.disconnectI � �� �
���8�$r c �x >� [ TU ] " U0 UD6 H% nUc M [ R " U5 ( d M% e g r )r> r. r< � isawaitable)r r+ r, �retr@ s �r �send�_SyncSignal.sendL s6 �� ��7�>�4�2�6�2�C��;�g�&9�&9�#�&>�&>� >�>� 3r r7 )r# �Callable[P, None]r0 r1 �r+ zP.argsr, zP.kwargsr0 r1 � r2 r3 r4 r5 r$ r( rI r6 �
__classcell__�r@ s @r r9 r9 D s �� �"�%�?� ?r r9 c �L ^ � \ rS rSrSU 4S jjrSU 4S jjrSU 4S jjrSrU =r$ )� _AsyncSignal�Q c �$ >� [ TU ] U5 g r )r> r$ r? s �r r$ �_AsyncSignal.connectR s �� �
����!r c �$ >� [ TU ] U5 g r rC r? s �r r( �_AsyncSignal.disconnectU rE r c � �� ># � [ R " [ TU ] " U0 UD6 Vs/ s H' nUc M [ R24 " U5 ( d M% UPM) sn6 I S h v�N g s snf N257fr )�asyncio�gatherr> r. r< rG )r r+ r, �awsr@ s �r rI �_AsyncSignal.sendX sg �� � ��n�n� !�7�>�4�:�6�:��:�C�� �'.�':�':�3�'?� �:��26� 27� 28��� 29�s' �#A(�A!�A!�A!�A(�A&� A(r7 )r# �#Callable[P, Awaitable[None] | None]r0 r1 rL rM rO s @r rQ rQ Q s �� �"�%�30� 31r rQ c �@ � [ [ [ [ 5 5 $ )a 32Create a synchronous signal with the given function signature for receivers.33 34Example:35 36 s = SyncSignal(lambda event: None) # all receivers must accept a single "event" argument.37 def receiver(event):38 print(event)39 40 s.connect(receiver)41 s.send("foo") # prints foo42 s.send(event="bar") # prints bar43 44 def receiver2():45 ...46 47 s.connect(receiver2) # mypy complains about receiver2 not having the right signature48 49 s2 = SyncSignal(lambda: None) # this signal has no arguments50 s2.send()51)r r9 r ��
receiver_specs r �52SyncSignalr` c s � �, � �A�� �
� .�.r c �@ � [ [ [ [ 5 5 $ )z�53Create an signal that supports both regular and async receivers:54 55Example:56 57 s = AsyncSignal(lambda event: None)58 async def receiver(event):59 print(event)60 s.connect(receiver)61 await s.send("foo") # prints foo62)r rQ r r^ s r � AsyncSignalrb } s � � � �Q�� � � 0�0r )r r r0 zweakref.ReferenceType)r_ rK r0 z_SyncSignal[P])r_ r\ r0 z_AsyncSignal[P])�__doc__�63__future__r rX r< r �collections.abcr r �typingr r r r r64 r r r r r9 rQ r` rb r7 r r �<module>rg s~ ��� #� � � � %� $� � � � � �
�c�N�� �C�L�� �L� L�865?�'�!�*�l� 66?�67�7�1�:�|� 68�$/�4 1r