File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_queues.cpython-310.opt-2.pyc
o
�iiJ � @ s� d dl Z d dlZd dlmZ d dlmZ dd� ZG dd� dej�Z G dd � d e �Z
G d
d� de �ZG dd
� d
e �ZG dd� de �Z
G dd� de �ZG dd� d�ZG dd� dee �ZG dd� dee �ZG dd� dee �Zedkrve �� dS dS )� N)�GenericAlias)�utilsc C s t �d � d S �N)�asyncioZset_event_loop_policy� r r �:/usr/local/lib/python3.10/test/test_asyncio/test_queues.py�tearDownModule s r c s e Zd Z� fdd�Z� ZS )�_QueueTestBasec s t � �� | �� | _d S r )�super�setUp�
new_test_loop�loop��self�� __class__r r r s
z_QueueTestBase.setUp)�__name__�
__module__�__qualname__r �
__classcell__r r r r r
s r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zdd� Zd
d� Z dd� Z
dS )�QueueBasicTestsc s� �fdd�}�� |��t�� }��� |��d�� |�� tt|��� |�v }��||� � ��fdd�}��|� � � ��fdd�}��|� � t�� }|� d� ��d � |�v � d S )
Nc 3 �0 � d V } � � d| � dV } � � d| � dV d S �N皙�����?g�������?��assertAlmostEqual�Zwhenr r r �gen � �
z.QueueBasicTests._test_repr_or_str.<locals>.genz<Queuec � sH �t �� } ��| �� � t �d�I d H ��d� | �v � | �d� d S )Nr z_getters[1]r )r �Queue�create_task�get�sleep�
assertTrue�
put_nowait��q��fnr
r r r �
add_getter* s �z5QueueBasicTests._test_repr_or_str.<locals>.add_getterc � sV �t jdd�} | �d� ��| �d�� t �d�I d H ��d� | �v � | �� d S )N� ��maxsize� r z_putters[1])r r r$ r �putr"