File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_sock_lowlevel.cpython-310.pyc
o
�iFH � @ sJ d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZ d dlm Z
d dlmZ d dl
mZ dd� ZG d d
� d
ej�ZG dd� d�Zejd
kr^G dd� dee
j�ZG dd� dee
j�Zn;d dlZeed�rqG dd� dee
j�Zeed�r�G dd� dee
j�Zeed�r�G dd� dee
j�ZG dd� dee
j�Zedkr�e�� dS dS )� N)�proactor_events)�cycle�islice)�utils)�support)�
socket_helperc C s t �d � d S �N)�asyncioZset_event_loop_policy� r
r
�A/usr/local/lib/python3.10/test/test_asyncio/test_sock_lowlevel.py�tearDownModule
� r c @ sF e Zd ZdZdZddd�Zdd� Zdd� Zdd � Zd
d� Z dd
� Z
dS )�MyProtoNc C s6 d | _ d| _d| _|d ur|�� | _|�� | _d S d S )N�INITIALr )� transport�state�nbytesZ
create_future� connected�done)�self�loopr
r
r �__init__ s
�zMyProto.__init__c G s$ | j |vrtd| j �d|����d S )Nzstate: z, expected: )r �AssertionError)r �expectedr
r
r �
_assert_state s
�zMyProto._assert_statec C s6 || _ | �d� d| _| jr| j�d � |�d� d S )Nr � CONNECTEDs% GET / HTTP/1.0
Host: example.com
)r r r r �
set_result�write)r r r
r
r �connection_made! s
zMyProto.connection_madec C s | � d� | jt|�7 _d S )Nr )r r �len)r �datar
r
r �
data_received) s
zMyProto.data_receivedc C s | � d� d| _d S )Nr �EOF)r r �r r
r
r �eof_received- s
zMyProto.eof_receivedc C s, | � dd� d| _| jr| j�d � d S d S )Nr r"