B
    b
,c¯  ã               @   s    d dl Z d dlmZ dd„ ZdS )é    N)ÚPollerc             C   sp   t ƒ }|dkr|}| |tj¡ | |tj¡ x<t| ¡ ƒ}||krR| | ¡ ¡ ||kr0| | ¡ ¡ q0W dS )a‚  Start a zeromq device (gevent-compatible).

    Unlike the true zmq.device, this does not release the GIL.

    Parameters
    ----------
    device_type : (QUEUE, FORWARDER, STREAMER)
        The type of device to start (ignored).
    isocket : Socket
        The Socket instance for the incoming traffic.
    osocket : Socket
        The Socket instance for the outbound traffic.
    éÿÿÿÿN)r   ÚregisterÚzmqZPOLLINÚdictZpollZsend_multipartZrecv_multipart)Zdevice_typeZisocketZosocketÚpZevents© r   ú/lib/python3.7/site-packages/zmq/green/device.pyÚdevice   s    r
   )r   Z	zmq.greenr   r
   r   r   r   r	   Ú<module>   s   