B lU\"@sdZdZddZddlmZddlmZmZm Z m Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZddd d d d d ddddddddddddddddddd d!d"d#d$d%d&d'd(g"ZeZejZejZejZej Z ej!Z!ej"Z"ej#Z#ej$Z$ej%Z%ej&Z&ej'Z'ed)d*d+Z(e)Z*e*+Z,e*j-Z.d3e/d)d-d Z0d4d.d Z1e/d)d/d Z2ed)d0dZ3e*j4Z5e*j6Z7e*j8Z9eed)d1d2Z:d,S)5a This is the main entry-point to pubsub's core functionality. The :mod:`~pubsub.pub` module supports: * messaging: publishing and receiving messages of a given topic * tracing: tracing pubsub activity in an application * trapping exceptions: dealing with "badly behaved" listeners (ie that leak exceptions) * specificatio of topic tree: defining (or just documenting) the topic tree of an application; message data specification (MDS) The recommended usage is :: from pubsub import pub // use pub functions: pub.sendMessage(...) Note that this module creates a "default" instance of pubsub.core.Publisher and binds several local functions to some of its methods and those of the pubsub.core.TopicManager instance that it contains. However, an application may create as many independent instances of Publisher as required (for instance, one in each thread; with a custom queue to mediate message transfer between threads). z $Rev: 243 $)List) Publisher AUTO_TOPICListenerMismatchErrorTopicDefnErrorIListenerExcHandlerExcHandlerErrorrTopicNameErrorUnrecognizedSourceFormatErrorSenderUnknownMsgDataErrorSenderMissingReqdMsgDataError TopicManager ALL_TOPICSTopicMessageDataSpecErrorexportTopicTreeSpecTOPIC_TREE_FROM_MODULETOPIC_TREE_FROM_STRINGTOPIC_TREE_FROM_CLASSTopicTreeTraverserINotificationHandler subscribe unsubscribeunsubAll isSubscribedisValidvalidaterrr getListenerExcHandlersetListenerExcHandlerr rr topicTreeRoot topicsMaprgetDefaultTopicMgraddTopicDefnProviderclearTopicDefnProvidersgetNumTopicDefnProvidersrrrrZ)instantiateAllDefinedTopicsTopicDefnErrorr setTopicUnspecifiedFatal sendMessageaddNotificationHandlersetNotificationFlagsgetNotificationFlagsclearNotificationHandlersr)returncCstS)z Get the Publisher instance created by default when this module is imported. See the module doc for details about this instance. ) _publisherr/r/)lib/python3.7/site-packages/pubsub/pub.pygetDefaultPublishersr1NcCst|j||dS)a Return true only if listener can subscribe to messages of given topic. If curriedArgNames can be a list of parameters of the given listener, that should be assumed curried (i.e. actual listener signature is signature of given listener minus curried args). )curriedArgNames) _topicMgrgetTopicr)listener topicNamer2r/r/r0rscCst|j||ddS)z Checks if listener can subscribe to topicName. If not, raises ListenerMismatchError, otherwise just returns. The curriedArgNames is same as for isValid(). )r2N)r3r4r)r5r6r2r/r/r0rscCst||S)z Returns true if listener has subscribed to topicName, false otherwise. WARNING: a false return is not a guarantee that listener won't get messages of topicName: it could receive messages of a subtopic of topicName. )r3r4Z hasListener)r5r6r/r/r0rscCstS)z Get the TopicManager instance created by default when this module is imported. This function is a shortcut for ``pub.getDefaultPublisher().getTopicMgr()``. )r3r/r/r/r0r#scCs*g}x |D]}t|||q W|S)ag Loop over all topics of given provider and "instantiate" each topic, thus forcing a parse of the topics documentation, message data specification (MDS), comparison with parent MDS, and MDS documentation. Without this function call, an error among any of those characteristics will manifest only if the a listener is registered on it. )r3ZgetOrCreateTopicappend)ZproviderZ all_topicsZ topic_namer/r/r0instantiateAllDefinedTopicss   r8)N)N);__doc__Z VERSION_APIsplitZ VERSION_SVNtypingrZcorerrrrr r r r r rrrrrrrrrrr__all__r.rrrr(rr r)r,r*r+r'r1Z getTopicMgrr3ZgetRootAllTopicsr!Z _topicsMapr"boolrrrr#ZaddDefnProviderr$ZclearDefnProvidersr%ZgetNumDefnProvidersr&r8r/r/r/r0s|  \"