File: //usr/lib/python3/dist-packages/twisted/test/__pycache__/test_stateful.cpython-38.pyc
U
W[� � @ st d Z ddlmZ ddlmZ ddlmZ ddlmZm Z m
Z
G dd� de�ZG dd � d e�ZG d
d� deej
�ZdS )
z+
Test cases for twisted.protocols.stateful
� )�TestCase)�
test_basic)�StatefulProtocol)�pack�unpack�calcsizec @ sP e Zd ZdZdZdZee�Zdd� Zdd� Z dd � Z
d
d� Zdd
� Zdd� Z
dS )�MyInt32StringReceiverz)
A stateful Int32StringReceiver.
i�� z!Ic C s
| j dfS �N� )�
_getHeader��self� r �</usr/lib/python3/dist-packages/twisted/test/test_stateful.py�getInitialState s z%MyInt32StringReceiver.getInitialStatec C s | j �� d S �N)� transportZloseConnection)r
�lengthr r r �lengthLimitExceeded s z)MyInt32StringReceiver.lengthLimitExceededc C s. t d|�\}|| jkr$| �|� d S | j|fS )N�!i)r �
MAX_LENGTHr �
_getString)r
�msgr r r r r s
z MyInt32StringReceiver._getHeaderc C s | � |� | jdfS r )�stringReceivedr �r
r r r r r ( s
z MyInt32StringReceiver._getStringc C s t �dS )z
Override this.
N)�NotImplementedErrorr r r r r - s z$MyInt32StringReceiver.stringReceivedc C s | j �t| jt|��| � dS )zS
Send an int32-prefixed string to the other end of the connection.
N)r �writer �structFormat�len)r
�datar r r �
sendString4 s z MyInt32StringReceiver.sendStringN)�__name__�
__module__�__qualname__�__doc__r r r ZprefixLengthr r r r r r r r r r r s r c @ s, e Zd Zdd� Zdd� ZdZdZdd� Zd S )
� TestInt32c C s
g | _ d S r )�receivedr r r r �connectionMade= s zTestInt32.connectionMadec C s | j �|� d S r )r&