B @\@sdZddlmZmZmZmZddlZeeZ ddl m Z ddl m Z dZGdd d eZGd d d eZGd d d eZGdddeZGdddeZdS)zf Provide classes to represent callback code that can be associate with Bokeh Documents and Sessions. )absolute_importdivisionprint_functionunicode_literalsN)make_id)_CallbackGroup)NextTickCallbackPeriodicCallbackSessionCallbackTimeoutCallbackc@s:eZdZdZd ddZeddZeddZd d ZdS) r zZ A base class for callback objects associated with Bokeh Documents and Sessions. NcCs$|dkrtn||_||_||_dS)z Args: document (Document) : callback (callable) : id (str, optional) : N)r_id _document _callback)selfdocumentcallbackidr5lib/python3.7/site-packages/bokeh/server/callbacks.py__init__4s zSessionCallback.__init__cCs|jS)z( A unique ID for this callback )r )rrrrrCszSessionCallback.idcCs|jS)z1 The callable that this callback wraps. )r)rrrrrJszSessionCallback.callbackcCs tddS)z4 Dev API used to wrap the callback with decorators. _copy_with_changed_callbackN)NotImplementedError)r new_callbackrrrrQsz+SessionCallback._copy_with_changed_callback)N) __name__ __module__ __qualname____doc__rpropertyrrrrrrrr /s    r cs*eZdZdZdfdd ZddZZS)r zE Represent a callback to execute on the next ``IOLoop`` "tick". Ncstt||||dS)z Args: document (Document) : callback (callable) : id (str, optional) : N)superr r)rrrr) __class__rrr]s zNextTickCallback.__init__cCst|j||jS)z4 Dev API used to wrap the callback with decorators. )r rr )rrrrrrjsz,NextTickCallback._copy_with_changed_callback)N)rrrrrr __classcell__rr)r rr Ys r cs6eZdZdZd fdd ZeddZddZZS) r zp Represent a callback to execute periodically on the ``IOLoop`` at a specified periodic time interval. Ncstt||||||_dS)z Args: document (Document) : callback (callable) : period (int) : id (str, optional) : N)rr r_period)rrrperiodr)r rrrss zPeriodicCallback.__init__cCs|jS)zc The period time (in milliseconds) that this callback should repeat execution at. )r")rrrrr#szPeriodicCallback.periodcCst|j||j|jS)z4 Dev API used to wrap the callback with decorators. )r rr"r )rrrrrrsz,PeriodicCallback._copy_with_changed_callback)N) rrrrrrr#rr!rr)r rr ns r cs6eZdZdZd fdd ZeddZddZZS) r zi Represent a callback to execute once on the ``IOLoop`` after a specified time interval passes. Ncstt||||||_dS)z Args: document (Document) : callback (callable) : timeout (int) : id (str, optional) : N)rr r_timeout)rrrtimeoutr)r rrrs zTimeoutCallback.__init__cCs|jS)zL The timeout (in milliseconds) that the callback should run after. )r$)rrrrr%szTimeoutCallback.timeoutcCst|j||j|jS)z4 Dev API used to wrap the callback with decorators. )r rr$r )rrrrrrsz+TimeoutCallback._copy_with_changed_callback)N) rrrrrrr%rr!rr)r rr s r c@s:eZdZdZd ddZddZddZd d Zd d ZdS)_DocumentCallbackGroupz NcCst||_dS)z N)r_group)rZio_looprrrrsz_DocumentCallbackGroup.__init__cCs|jdS)z N)r'remove_all_callbacks)rrrrr(sz+_DocumentCallbackGroup.remove_all_callbackscCsx|D]}||qWdS)z N)add_session_callback)rZ callbackscbrrradd_session_callbackss z,_DocumentCallbackGroup.add_session_callbackscCstt|tr"|j|j|j|jnNt|trD|j|j|j |jn,t|t rb|j |j|jnt d|jdS)z zVExpected callback of type PeriodicCallback, TimeoutCallback, NextTickCallback, got: %sN) isinstancer r'Zadd_periodic_callbackrr#rr Zadd_timeout_callbackr%r Zadd_next_tick_callback ValueError)r callback_objrrrr)s   z+_DocumentCallbackGroup.add_session_callbackcCsjyPt|tr|j|jn2t|tr6|j|jnt|trN|j|jWnt k rdYnXdS)z N) r,r r'Zremove_periodic_callbackrr Zremove_timeout_callbackr Zremove_next_tick_callbackr-)rr.rrrremove_session_callbacks    z._DocumentCallbackGroup.remove_session_callback)N) rrrrrr(r+r)r/rrrrr&s   r&)rZ __future__rrrrZloggingZ getLoggerrlogZutil.serializationrZ util.tornador__all__objectr r r r r&rrrr s   *!$