Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/devices/__pycache__/monitoredqueuedevice.cpython-39.pyc
Ðазад
a a�h� � @ s� d Z ddlmZmZ ddlmZmZmZmZ ddl m Z G dd� de�Z G dd� de e�Z G d d � d e e�Z G d d � d e e�Zg d �ZdS )z%MonitoredQueue classes and functions.� )�ZMQError�PUB)� ProxyBase�Proxy� ThreadProxy� ProcessProxy)�monitored_queuec @ s0 e Zd ZdZdZdZeddfdd�Zdd� Zd S ) �MonitoredQueueBasez"Base class for overriding methods.� s ins outc C s" t j| |||d� || _|| _d S )N)�in_type�out_type�mon_type)r �__init__� _in_prefix� _out_prefix)�selfr r r Z in_prefixZ out_prefix� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/devices/monitoredqueuedevice.pyr s zMonitoredQueueBase.__init__c C s& | � � \}}}t|||| j| j� d S )N)Z_setup_socketsr r r )r ZinsZoutsZmonsr r r � run_device s z MonitoredQueueBase.run_deviceN) �__name__� __module__� __qualname__�__doc__r r r r r r r r r r s r c @ s e Zd ZdZdS )�MonitoredQueueaY Class for running monitored_queue in the background. See zmq.devices.Device for most of the spec. MonitoredQueue differs from Proxy, only in that it adds a ``prefix`` to messages sent on the monitor socket, with a different prefix for each direction. MQ also supports ROUTER on both sides, which zmq.proxy does not. If a message arrives on `in_sock`, it will be prefixed with `in_prefix` on the monitor socket. If it arrives on out_sock, it will be prefixed with `out_prefix`. A PUB socket is the most logical choice for the mon_socket, but it is not required. N�r r r r r r r r r s r c @ s e Zd ZdZdS )�ThreadMonitoredQueue�gRun zmq.monitored_queue in a background thread. See MonitoredQueue and Proxy for details. Nr r r r r r / s r c @ s e Zd ZdZdS )�ProcessMonitoredQueuer Nr r r r r r 7 s r )r r r N)r Zzmqr r Zzmq.devices.proxydevicer r r r Zzmq.devices.monitoredqueuer r r r r �__all__r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка