ó
úR‹_c           @  s  d  d l  m Z d  d l Z d  d l Z d  d l Z y d  d l Z Wn e k
 rc d  d l Z n Xe j ƒ  Z	 e	 j
 j ƒ  Z e e	 j
 d ƒ s— t ‚ e j d e j e j d ƒ e j ƒ  Z e j d ƒ  e	 j e ƒ Wd QXe d e e j ƒ  e d f ƒ d S(   iÿÿÿÿ(   t   print_functionNt   asyncgš™™™™™¹?g      ð?s%   Watcher %r reacted after %.6f seconds(    (   t
   __future__R    t   geventt   gevent.coret   timet   threadt   ImportErrort   _threadt   get_hubt   hubt   loopt   async_t   watchert   hasattrt   AssertionErrort   spawn_latert   start_new_threadt   sendt   startt   Timeoutt   waitt   print(    (    (    sV   /var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__core_async.pyt   <module>   s   