h SrSSKrSSKJrJrJr "SS5r"SS\\5r"SS \\5r"S S \\5r /S Qr g) zProxy classes and functions.N)Device ProcessDevice ThreadDevicec\\rSrSrSr\R 4SjrSrSr Sr Sr Sr S r S rg ) ProxyBase z"Base class for overriding methods.cd[R"XUS9 X0l/Ul/Ul/Ulg)N)in_typeout_type)r__init__mon_type _mon_binds _mon_connects _mon_sockopts)selfr r r s jC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\zmq/devices/proxydevice.pyr ProxyBase.__init__ s,A c:URRU5 g)zQEnqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details. N)rappendraddrs rbind_monProxyBase.bind_mons t$rc^UR"U/UQ70UD6nURUSU35 U$)zEnqueue a random port on the given interface for binding on mon_socket. See zmq.Socket.bind_to_random_port for details. .. versionadded:: 18.0 :)_reserve_random_portr)rrargskwargsports rbind_mon_to_random_port!ProxyBase.bind_mon_to_random_ports:((??? av&' rc:URRU5 g)zWEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N)rrrs r connect_monProxyBase.connect_mon)s !!$'rc<URRX45 g)zVEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N)rr)roptvalues rsetsockopt_monProxyBase.setsockopt_mon0s !!3,/rc[R"U5upURnURUR5nUR R U5 URHupVURXV5 M URHnURU5 M URHnURU5 M XU4$N) r_setup_sockets_contextsocketr _socketsrr setsockoptrbindrconnect)rinsoutsctxmonsr'r(ifaces rr-ProxyBase._setup_sockets7s))$/ mmzz$--( T",,JC OOC '-__E IIe %''E LL ($rcXUR5upn[R"XU5 gr,)r-zmqproxy)rr4r5r7s r run_deviceProxyBase.run_deviceIs"--/4 #T"r)rrrr N)__name__ __module__ __qualname____firstlineno____doc__r;PUBr rr!r$r)r-r=__static_attributes__rrrr s/,3677 % (0$#rrc\rSrSrSrSrg)ProxyNaThreadsafe Proxy object. See zmq.devices.Device for most of the spec. This subclass adds a _mon version of each _{in|out} method, for configuring the monitor socket. A Proxy is a 3-socket ZMQ Device that functions just like a QUEUE, except each message is also sent out on the monitor socket. A PUB socket is the most logical choice for the mon_socket, but it is not required. rFNr?r@rArBrCrErFrrrHrHNs rrHc\rSrSrSrSrg) ThreadProxy\z&Proxy in a Thread. See Proxy for more.rFNrJrFrrrLrL\s0rrLc\rSrSrSrSrg) ProcessProxy`z'Proxy in a Process. See Proxy for more.rFNrJrFrrrOrO`s1rrO)rHrLrO) rCr;zmq.devices.basedevicerrrrrHrLrO__all__rFrrrSsQ"  FFA#A#H Iv 1)\129m2 r