o
    ṏi                     @  s,   d dl mZ d dlZd dlmZ dd ZdS )    )annotationsN)Pollerc                 C  sj   t  }|dkr	|}||tj ||tj 	 t| }||v r)||  ||v r4||  q)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.
    )r   registerzmqPOLLINdictpollsend_multipartrecv_multipart)device_typeisocketosocketpevents r   M/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/zmq/green/device.pydevice	   s   r   )
__future__r   r   	zmq.greenr   r   r   r   r   r   <module>   s   