"dndZddlmZddlZddlZddlZej eZddZ Gdde Z y)zThe filesystem watcher api.)absolute_importNcfd}|S)zRetry a function or method n times before raising an exception. :param n: Number of times to retry :param interval: Time to sleep before attempts cHtjfd}|S)Nc|d} |i|S#t$r#|dz }|krtjYnwxYw9)Nr) Exceptiontimesleep)argskwargsattemptsfnintervalns 5/usr/lib/python3/dist-packages/qtsass/watchers/api.pyattemptz(retry..decorate..attemptsSH)t.v.. )MHH}JJx( )s )::) functoolswraps)rrrrs` rdecoratezretry..decorates%   )  ))rrrs`` rretryrs  OrcjeZdZdZddZdZdZdZdZe dd Z d Z d Z d Z d ZdZy)WatcheraWatcher base class. Watchers monitor a file or directory and call the on_change method when a change occurs. The on_change method should trigger the compiler function passed in during construction and dispatch the result to all connected callbacks. Watcher implementations must inherit from this base class. Subclasses should perform any setup required in the setup method, rather than overriding __init__. Nc||_||_|xsd|_|xsi|_t |_t |_|jy)z3Store initialization values and call Watcher.setup.rN) _watch_dir _compiler_args_kwargsset _callbacks_logsetup)self watch_dircompilerr r s r__init__zWatcher.__init__?s?#!ZR | %  rctS)zPerform any setup required here. Rather than implement __init__, subclasses can perform any setup in this method. NotImplementedr$s rr#z Watcher.setupIs rctS)zStart this Watcher.r)r+s rstartz Watcher.startQrctS)zStop this Watcher.r)r+s rstopz Watcher.stopUr.rctS)z Wait for this Watcher to finish.r)r+s rjoinz Watcher.joinYr.rc|jjd|j|j|j|j|ji|jS)zCall the Watcher's compiler.zCompiling sass...%s(*%s, **%s))r"debugrrrr+s rcompilezWatcher.compile]sL  , NN JJ LL  t~~tzz:T\\::rc|jjd |j}|j |y#t$r|jj dYywxYw)z>Compile and dispatch the resulting css to connected callbacks.zCompiling and dispatching....zFailed to compile...N)r"r5r6r exceptiondispatch)r$csss rcompile_and_dispatchzWatcher.compile_and_dispatchhsX 78 ,,.C c   II   6 7  s?$A&%A&cl|jjd|jD] }|| y)z$Dispatch css to connected callbacks.zDispatching callbacks...N)r"r5r!)r$r:callbacks rr9zWatcher.dispatchts- 23 H SM rcZ|jjd|jy)awCall when a change is detected. Subclasses must call this method when they detect a change. Subclasses may also override this method in order to manually compile and dispatch callbacks. For example, a Qt implementation may use signals and slots to ensure that compiling and executing callbacks happens in the main GUI thread. zChange detected...N)r"r5r;r+s r on_changezWatcher.on_changezs! ,- !!#rcr|jjd||jj|y)zConnect a callback to this Watcher. All callbacks are called when a change is detected. Callbacks are passed the compiled css. zConnecting callback: %sN)r"r5r!addr$rs rconnectzWatcher.connects) 126 Brcr|jjd||jj|y)z(Disconnect a callback from this Watcher.zDisconnecting callback: %sN)r"r5r!discardrBs r disconnectzWatcher.disconnects' 4b9 #r)NN)__name__ __module__ __qualname____doc__r'r#r-r0r2rr6r;r9r?rCrFrrrrr2sQ  1X;;  $ $rr)g?) rJ __future__rrloggingr getLoggerrGr"robjectrrrrrOsA"' w"4`$f`$r