B b ,c@s8UdZddlZddlZddlmZyDddlZddlmZddlmZe ej dsde de edd Wn,e k rd dl mZd dlmZYnXejZGd d d eZd dZde_eed<dejkrd dlmZn ej Zxeek reZqWGdddeZeZ ddZdejkr4d dlm Z mZmZdS)ztornado IOLoop API with zmq compatibility This module is deprecated in pyzmq 17. To use zmq with tornado, eventloop integration is no longer required and tornado itself should be used. N)Any)ioloop)gen_logconfigurable_defaultzTornado too old: %sversionunknowncs2eZdZdZd fdd ZddZddZZS) DelayedCallbackzSchedules the given callback to be called once. The callback is called once, after callback_time milliseconds. `start` must be called after the DelayedCallback is created. The timeout is calculated from when `start` is called. Ncs*tdtt|d}t|||dS)NzDDelayedCallback is deprecated. Use loop.add_timeout instead.gMbP?)warningswarnDeprecationWarningmaxsuper__init__)selfcallback callback_timeio_loop) __class__3lib/python3.7/site-packages/zmq/eventloop/ioloop.pyr+s  zDelayedCallback.__init__cCs6d|_d|_t|jd|_|j|j|jdS)zStarts the timer.Tg@@N)_runningZ _firstruntimerZ _next_timeoutrZ add_timeout_run)rrrrstart5szDelayedCallback.startcCsD|js dSd|_y |Wn"tk r>tjdddYnXdS)NFzError in delayed callbackT)exc_info)rr Exceptionrerror)rrrrr<s zDelayedCallback._run)N)__name__ __module__ __qualname____doc__rrr __classcell__rr)rrr !s r cCs$tjr dSdt_tjdtdddS)NTzlzmq.eventloop.ioloop is deprecated in pyzmq 17. pyzmq now works with default tornado and asyncio eventloops.) stacklevel) _deprecatedcalledr r r rrrrr%Fsr%F_IOLoopz .minitornado.) ZMQIOLoopcs8eZdZdZfddZeddZeddZZS)r(zDEPRECATED: No longer needed as of pyzmq-17 PyZMQ tornado integration now works with the default :mod:`tornado.ioloop.IOLoop`. csttS)N)r%rr)rargskwargs)rrrrdszZMQIOLoop.__init__cOs$tj|ttjj||}|S)aReturns a global `IOLoop` instance. Most applications have a single, global `IOLoop` running on the main thread. Use this method to get this instance from another thread. To get the current thread's `IOLoop`, use `current()`. )rIOLoop configurer%instance)clsr)r*looprrrr-is zZMQIOLoop.instancecOs$tj|ttjj||}|S)u&Returns the current thread’s IOLoop.)rr+r,r%current)r.r)r*r/rrrr0xs zZMQIOLoop.current) rrr r!r classmethodr-r0r"rr)rrr(^s  r(cCsttjtdS)zRDEPRECATED pyzmq 17 no longer needs any special integration for tornado. N)r%rr+r,r(rrrrinstallsr2)r+r(r2)r!rr typingrZtornadorZ tornado.logrhasattrr+ ImportErrorgetattrZ minitornadoZminitornado.logZPeriodicCallbackr r%r&__annotations__rr(r'rr2rrrrs8     %   &