�&ǐk�@'bJ�h�ۊL'}T� :��'2�Z#$��n�a��� �>a��`��_3d�Qpt�/�P -��#5�,�M��� �pA:©�q�����NW��ډ�A���� �9nʺج���� �TSM��{J6?7��r�@�\����D��� �׶���s�f�TJj?"��D��`?��̒� b�#�%�C*v�$�{�$����5Ծ�F�s��y�e/8��h-�f�̰&(����Gj�L:U� 2�� ����v�_k����Y��gp,�k�WF�R������_C�R��N@���R�@�ߔ?A�w9���F("iNa-S���Q�o�3tDMLh*�#4k�T/iQ��Y*�G��m����)��8�hBm/�I�,g�ﯖ���Z��}�Cz�q@´��d.����L�ŕ�,��1�Z�܌�: ̪���F+J-'��c�tvJ8��]Q-��b��y �6;*J`r_�d ��'�G ~p��)'�C,�%F��E(��2�k�����lР�z�!�=t ��_�0��f7��� ;�p�|�U �% CM [-> DR*] [-> ER?] -> CL -> end * CM: connection_made() * DR: data_received() * ER: eof_received() * CL: connection_lost() rcCsdS)zTCalled when some data is received. The argument is a bytes object. Nr)rdatarrr data_received^szProtocol.data_receivedcCsdSzCalled when the other end calls write_eof() or equivalent. If this returns a false value (including None), the transport will close itself. If it returns a true value, closing the transport is up to the protocol. Nrr rrr eof_receiveddszProtocol.eof_receivedN)rrrrrrrrrrrrBsrc@s,eZdZdZdZddZddZddZd S) raInterface for stream protocol with manual buffer control. Important: this has been added to asyncio in Python 3.7 *on a provisional basis*! Consider it as an experimental API that might be changed or removed in Python 3.8. Event methods, such as `create_server` and `create_connection`, accept factories that return protocols that implement this interface. The idea of BufferedProtocol is that it allows to manually allocate and control the receive buffer. Event loops can then use the buffer provided by the protocol to avoid unnecessary data copies. This can result in noticeable performance improvement for protocols that receive big amounts of data. Sophisticated protocols can allocate the buffer only once at creation time. State machine of calls: start -> CM [-> GB [-> BU?]]* [-> ER?] -> CL -> end * CM: connection_made() * GB: get_buffer() * BU: buffer_updated() * ER: eof_received() * CL: connection_lost() rcCsdS)aPCalled to allocate a new receive buffer. *sizehint* is a recommended minimal size for the returned buffer. When set to -1, the buffer size can be arbitrary. Must return an object that implements the :ref:`buffer protocol `. It is an error to return a zero-sized buffer. Nr)rsizehintrrr get_bufferszBufferedProtocol.get_buffercCsdS)zCalled when the buffer was updated with the received data. *nbytes* is the total number of bytes that were written to the buffer. Nr)rnbytesrrrbuffer_updatedszBufferedProtocol.buffer_updatedcCsdSrrr rrrrszBufferedProtocol.eof_receivedN)rrrrrrrrrrrrrms  rc@s$eZdZdZdZddZddZdS)rz Interface for datagram protocol.rcCsdS)z&Called when some datagram is received.Nr)rrZaddrrrrdatagram_receivedsz"DatagramProtocol.datagram_receivedcCsdS)z~Called when a send or receive operation raises an OSError. (Other than BlockingIOError or InterruptedError.) Nrr rrrerror_receivedszDatagramProtocol.error_receivedN)rrrrrrrrrrrrsrc@s,eZdZdZdZddZddZddZd S) rz,Interface for protocol for subprocess calls.rcCsdS)zCalled when the subprocess writes data into stdout/stderr pipe. fd is int file descriptor. data is bytes object. Nr)rfdrrrrpipe_data_receivedsz%SubprocessProtocol.pipe_data_receivedcCsdS)zCalled when a file descriptor associated with the child process is closed. fd is the int file descriptor that was closed. Nr)rrr rrrpipe_connection_lostsz'SubprocessProtocol.pipe_connection_lostcCsdS)z"Called when subprocess has exited.Nrr rrrprocess_exitedsz!SubprocessProtocol.process_exitedN)rrrrrr r!r"rrrrrs rcCst|}|r||}t|}|s*td||krL||d|<||dS|d||d|<||||d}t|}qdS)Nz%get_buffer() returned an empty buffer)lenr RuntimeErrorr)protorZdata_lenZbufZbuf_lenrrr_feed_data_to_buffered_protos     r&N)r__all__rrrrrr&rrrrs9+9