Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_zmqstream.cpython-39.pyc
Ðазад
a a�h� � @ s� d dl mZ z d dlZW n ey. dZY n0 d dlmZ d dlZd dlZz(d dlZd dlm Z d dl m Z m Z W n ey� dZY n0 G dd� de�Z dS )� )�absolute_importN)�TestCase)�gen)�ioloop� zmqstreamc @ s> e Zd Zdd� Zdd� Zddd�Zdd � Zd d � Zd d � ZdS )� TestZMQStreamc C s� t d u rt�� tr"t�t�� � t�� | _t � � | _ | j � � t �| j�tj��| _t �| j�tj��| _| j�d�}| j�d| � | j| _d S )Nztcp://127.0.0.1ztcp://127.0.0.1:%i)�tornado�pytest�skip�asyncioZset_event_loopZnew_event_loop�zmq�Context�contextr �IOLoop�loopZ make_currentr Z ZMQStream�socketZPUSH�pushZPULL�pullZbind_to_random_port�connect�stream)�self�port� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/test_zmqstream.py�setUp s zTestZMQStream.setUpc C s& | j jdd� | j�� tj�� d S )NT)Zall_fds)r �closer �termr r Z clear_current�r r r r �tearDown& s zTestZMQStream.tearDown� c sD g �t j� ��fdd���� j��fdd�� � j�� �r@J �d S )Nc 3 s( t ���V dg�d d �< � j�� d S )Nz timed out)r �sleepr �stopr )r � timed_out�timeoutr r � sleep_timeout- s z6TestZMQStream.run_until_timeout.<locals>.sleep_timeoutc s � � S �Nr r )r$ r r �<lambda>2 � z1TestZMQStream.run_until_timeout.<locals>.<lambda>)r � coroutiner � add_callback�start)r r# r )r r$ r" r# r �run_until_timeout+ s z TestZMQStream.run_until_timeoutc C sZ | j �dd� � | j �dd� � | �t| j jd� | �t| j jd� | �t| j jt� dS )z#Ensure callable check works (py3k).c W s d S r% r ��argsr r r r& 9 r' z3TestZMQStream.test_callable_check.<locals>.<lambda>c W s d S r% r r, r r r r& : r' � N)r Zon_send�on_recvZ assertRaises�AssertionErrorr r r r r �test_callable_check6 s z!TestZMQStream.test_callable_checkc sB dg�� �fdd�}� j �� �fdd�� � j�|� � �� d S )Ns basicc s | �ks J �� j �� d S r% �r r! ��msg�r �sentr r �callbackA s z2TestZMQStream.test_on_recv_basic.<locals>.callbackc s � j ���S r% �r Zsend_multipartr r5 r r r& D r' z2TestZMQStream.test_on_recv_basic.<locals>.<lambda>)r r) r r/ r+ �r r7 r r5 r �test_on_recv_basic? s z TestZMQStream.test_on_recv_basicc sD dg�� �fdd�}� j �|� � j�d� �fdd�� � �� d S )Ns wakec s | �ks J �� j �� d S r% r2 r3 r5 r r r7 J s z1TestZMQStream.test_on_recv_wake.<locals>.callbackr. c s � j ���S r% r8 r r5 r r r& N r' z1TestZMQStream.test_on_recv_wake.<locals>.<lambda>)r r/ r Z call_laterr+ r9 r r5 r �test_on_recv_wakeH s z TestZMQStream.test_on_recv_wakeN)r ) �__name__� __module__� __qualname__r r r+ r1 r: r; r r r r r s r )� __future__r r � ImportErrorZunittestr r r r r Z zmq.eventloopr r r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка