← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/anyio/streams/__pycache__/stapled.cpython-312.pyc
68 lines
�
c�bj� � �6 � d dl mZ dZd dlmZmZmZ d dlmZ d dl m
Z
m Z m Z ddl
mZmZmZmZmZmZmZmZ e d� Z e d � Z ed
� � G d � d
e� � Z ed
� � G d� de e ee � � Z ed
� � G d� de e ee � � Zy)� )� annotations)�
MultiListener�StapledByteStream�StapledObjectStream)�Callable�Mapping�Sequence)� dataclass)�Any�Generic�TypeVar� )�ByteReceiveStream�ByteSendStream�
ByteStream�Listener�ObjectReceiveStream�ObjectSendStream� ObjectStream� TaskGroup�T_Item�T_StreamF)�eqc �Z � e Zd ZU dZded< ded< d d
d�Zdd�Zdd�Zdd �Ze dd
�� Z
y )r aV
Combines two byte streams into a single, bidirectional byte stream.
Extra attributes will be provided from both streams, with the receive stream
providing the values in case of a conflict.
:param ByteSendStream send_stream: the sending byte stream
:param ByteReceiveStream receive_stream: the receiving byte stream
r � send_streamr �receive_streamc � �t K � |dk r t d� �| j j |� � d { ��� S 7 ��w)N� z$max_bytes must be a positive integer)�
ValueErrorr �receive)�self� max_bytess �l/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/anyio/streams/stapled.pyr zStapledByteStream.receive+ s6 � �� � �q�=� � C�D� D��(�(�0�0��;�;�;�;�s �/8�6�8c � �V K � | j j |� � d { ��� y 7 ��w�N�r �send�r! �items r# r' zStapledByteStream.send1 � � �� �� � �#�#�D�)�)�)�� � )�'�)c � �T K � | j j � � d { ��� y 7 ��wr% �r �aclose�r! s r# �send_eofzStapledByteStream.send_eof4 � � �� �� � �%�%�'�'�'�� � (�&�(c � � K � | j j � � d { ��� | j j � � d { ��� y 7 �'7 ��wr% �r r. r r/ s r# r. zStapledByteStream.aclose7 �? � �� �� � �%�%�'�'�'��!�!�(�(�*�*�*� (��*��! � A �A�!A �A
�A �
A c �^ � i | j j �| j j �S r% �r �extra_attributesr r/ s r# r9 z"StapledByteStream.extra_attributes; �4 � �
�� � �/�/�
��!�!�2�2�
�
� N)i )r" �int�return�bytes)r) r> r= �None�r= r? �r= z Mapping[Any, Callable[[], Any]]� �__name__�
__module__� __qualname__�__doc__�__annotations__r r' r0 r. �propertyr9 � r; r# r r s= � �� � �%�%�<� *�(�+� �
� �
r; r c �X � e Zd ZU dZded< ded< d d�Zd
d�Zdd�Zdd �Ze dd
�� Z
y )r ab
Combines two object streams into a single, bidirectional object stream.
Extra attributes will be provided from both streams, with the receive stream
providing the values in case of a conflict.
:param ObjectSendStream send_stream: the sending object stream
:param ObjectReceiveStream receive_stream: the receiving object stream
zObjectSendStream[T_Item]r zObjectReceiveStream[T_Item]r c � �R K � | j j � � d { ��� S 7 ��wr% )r r r/ s r# r zStapledObjectStream.receiveR s! � �� ��(�(�0�0�2�2�2�2�s � '�%�'c � �V K � | j j |� � d { ��� y 7 ��wr% r& r( s r# r' zStapledObjectStream.sendU r* r+ c � �T K � | j j � � d { ��� y 7 ��wr% r- r/ s r# r0 z StapledObjectStream.send_eofX r1 r2 c � � K � | j j � � d { ��� | j j � � d { ��� y 7 �'7 ��wr% r4 r/ s r# r. zStapledObjectStream.aclose[ r5 r6 c �^ � i | j j �| j j �S r% r8 r/ s r# r9 z$StapledObjectStream.extra_attributes_ r: r; N)r= r )r) r r= r? r@ rA rB rI r; r# r r C s= � �� *�)�/�/�3�*�(�+� �
� �
r; r c �T � e Zd ZU dZded< d d�Z d
d d�Zd d�Zed d�� Z y)
r a�
Combines multiple listeners into one, serving connections from all of them at once.
Any MultiListeners in the given collection of listeners will have their listeners
moved into this one.
Extra attributes are provided from each listener, with each successive listener
overriding any conflicting attributes from the previous one.
:param listeners: listeners to serve
:type listeners: Sequence[Listener[T_Stream]]
z Sequence[Listener[T_Stream]]� listenersc �� � g }| j D ]N }t |t � r+|j |j � |j d d �= �>|j |� �P || _ y r% )rQ �
isinstancer �extend�append)r! rQ �listeners r# �
__post_init__zMultiListener.__post_init__x sX � �.0� � ���H��(�M�2�� � ��!3�!3�4� �&�&�q�)�� � ��*� '� #��r; Nc � �� K � ddl m} |� 4 �d { ��� }| j D ] }|j |j ||� �! d d d � �d { ��� y 7 �C7 �# 1 �d { ���7 sw Y y xY w�w)Nr )�create_task_group)� rY rQ �
start_soon�serve)r! �handler�
task_grouprY �tgrV s r# r\ zMultiListener.serve� sQ � �� � )�$�&�&�"� �N�N���
�
�h�n�n�g�z�B� +� '�&�&��&��&�&�&�sD �A1�A�A1�/A � A1�A�A1�A1� A.�"A% �#A.�*A1c � �b K � | j D ] }|j � � d { ��� � y 7 ��wr% )rQ r. )r! rV s r# r. zMultiListener.aclose� s' � �� � ���H��/�/�#� #� #� '� #�s �#/�-�/c �b � i }| j D ] }|j |j � � |S r% )rQ �updater9 )r! �
attributesrV s r# r9 z MultiListener.extra_attributes� s1 � � �
� ���H� � � �h� 7� 7� 8� '� �r; r@ r% )r] zCallable[[T_Stream], Any]r^ zTaskGroup | Noner= r? rA )
rC rD rE rF rG rW r\ r. rH r9 rI r; r# r r g sU � � � ,�+� #� RV�C�0�C�>N�C�
�C�$� �� �r; r N)�
__future__r �__all__�collections.abcr r r � dataclassesr
�typingr r r
�abcr r r r r r r r r r r r r rI r; r# �<module>rj s� �� "� �� 8� 7� !� (� (� � � �
�� �� �:� �� �e��#
�
� #
� �#
�L �e��
�'�&�/�<��+?�
� �
�F �e��.�G�H�%�x��'9� .� �.r;