-erdZddlmZddlZejeZddlZddlm Z ddl m Z m Z m Z mZmZmZmZe rddlmZdd lmZmZd Zed e d e f ZGddeeZddZdZGddZdS)z ) annotationsN)wraps) TYPE_CHECKINGAnyCallableLiteralProtocolTypeVarcast)NextTickCallback)CallbackDocument)UnlockedDocumentProxywithout_document_lockF.)boundc$eZdZUded<ded<dS)NoLockCallbackr__call__z Literal[True]nolockN)__name__ __module__ __qualname____annotations__6lib/python3.11/site-packages/bokeh/document/locking.pyrr8s'KKKrrfuncreturnNoLockCallback[F]ctjrtd fd }ntd fd }ttt |}d|_|S) ap Wrap a callback function to execute without first obtaining the document lock. Args: func (callable) : The function to wrap Returns: callable : a function wrapped to execute without a |Document| lock. While inside an unlocked callback, it is completely *unsafe* to modify ``curdoc()``. The value of ``curdoc()`` inside the callback will be a specially wrapped version of |Document| that only allows safe operations, which are: * :func:`~bokeh.document.Document.add_next_tick_callback` * :func:`~bokeh.document.Document.remove_next_tick_callback` Only these may be used safely without taking the document lock. To make other changes to the document, you must add a next tick callback and make your changes to ``curdoc()`` from that second callback. Attempts to otherwise access or change the Document will result in an exception being raised. ``func`` can be a synchronous function, an async function, or a function decorated with ``asyncio.coroutine``. The returned function will be an async function if ``func`` is any of the latter two. argsrkwr!Nonec(K|i|d{VdSNrr$r%r s r_wrapperz'without_document_lock.._wrapper[s4$### # # # # # # # # #rc|i|dSr(rr)s rr*z'without_document_lock.._wrapper_s D$ "     rT)r$rr%rr!r&)asyncioiscoroutinefunctionrr rrr)r r*wrappers` rrr<s<"4(( t $ $ $ $ $  $ $ t       >!$h//GGN NrzOnly 'add_next_tick_callback' may be used safely without taking the document lock; to make other changes to the document, add a next tick callback and make your changes from that callback.c2eZdZdZddZdd ZddZddZdS)rz Wrap a Document object so that only methods that can safely be used from unlocked callbacks or threads are exposed. Attempts to otherwise access or change the Document results in an exception. docrr!r&c||_dS) N)_doc)selfr0s r__init__zUnlockedDocumentProxy.__init__vs rattrstrrc*tt)r2)AttributeErrorUNSAFE_DOC_ATTR_USAGE_MSG)r4r6s r __getattr__z!UnlockedDocumentProxy.__getattr__|s6777rcallbackrr c6|j|S)zW Add a "next tick" callback. Args: callback (callable) : )r3add_next_tick_callbackr4r<s rr>z,UnlockedDocumentProxy.add_next_tick_callbacksy//999rc:|j|dS)zZ Remove a "next tick" callback. Args: callback (callable) : N)r3remove_next_tick_callbackr?s rrAz/UnlockedDocumentProxy.remove_next_tick_callbacks  ++H55555rN)r0rr!r&)r6r7r!r)r<rr!r )r<r r!r&)rrr__doc__r5r;r>rArrrrrosn  8888 ::::666666rr)r rr!r")rB __future__rlogging getLoggerrlogr, functoolsrtypingrrrrr r r server.callbacksr documentrr__all__rrrr:rrrrrLs#"""""g!!-333333,,,,,,,,   GCxS)***Xa[))))Z#6#6#6#6#6#6#6#6#6#6r